Update documentation (#862)

Co-authored-by: daniil-quix <[email protected]>

Author: github-actions[bot]

docs/api-reference/application.md

@@ -131,8 +131,8 @@ Linked Environment Variable: `Quix__State__Dir`.
 Default - `"state"`.
 - `rocksdb_options`: RocksDB options.
 If `None`, the default options will be used.
-- `consumer_poll_timeout`: timeout for `RowConsumer.poll()`. Default - `1.0`s
-- `producer_poll_timeout`: timeout for `RowProducer.poll()`. Default - `0`s.
+- `consumer_poll_timeout`: timeout for `InternalConsumer.poll()`. Default - `1.0`s
+- `producer_poll_timeout`: timeout for `InternalProducer.poll()`. Default - `0`s.
 - `on_message_processed`: a callback triggered when message is successfully
 processed.
 - `loglevel`: a log level for "quixstreams" logger.
@@ -160,11 +160,11 @@ To handle errors, `Application` accepts callbacks triggered when
     exceptions occur on different stages of stream processing. If the callback
     returns `True`, the exception will be ignored. Otherwise, the exception
     will be propagated and the processing will eventually stop.
-- `on_consumer_error`: triggered when internal `RowConsumer` fails
+- `on_consumer_error`: triggered when internal `InternalConsumer` fails
 to poll Kafka or cannot deserialize a message.
 - `on_processing_error`: triggered when exception is raised within
 `StreamingDataFrame.process()`.
-- `on_producer_error`: triggered when `RowProducer` fails to serialize
+- `on_producer_error`: triggered when `InternalProducer` fails to serialize
 or to produce a message to Kafka.
 <br><br>***Quix Cloud Parameters***<br>
 - `quix_config_builder`: instance of `QuixKafkaConfigsBuilder` to be used

docs/api-reference/kafka.md

@@ -10,7 +10,7 @@
 class Producer()
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L45)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L65)
 
 <a id="quixstreams.kafka.producer.Producer.__init__"></a>
 
@@ -23,10 +23,11 @@ def __init__(broker_address: Union[str, ConnectionConfig],
              logger: logging.Logger = logger,
              error_callback: Callable[[KafkaError], None] = _default_error_cb,
              extra_config: Optional[dict] = None,
-             flush_timeout: Optional[float] = None)
+             flush_timeout: Optional[float] = None,
+             transactional: bool = False)
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L46)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L66)
 
 A wrapper around `confluent_kafka.Producer`.
 
@@ -66,7 +67,7 @@ def produce(topic: str,
             on_delivery: Optional[DeliveryCallback] = None)
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L84)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L117)
 
 Produce a message to a topic.
 
@@ -101,7 +102,7 @@ for the produced message.
 def poll(timeout: float = 0)
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L145)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L178)
 
 Polls the producer for events and calls `on_delivery` callbacks.
 
@@ -122,7 +123,7 @@ Polls the producer for events and calls `on_delivery` callbacks.
 def flush(timeout: Optional[float] = None) -> int
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L153)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L213)
 
 Wait for all messages in the Producer queue to be delivered.
 
@@ -139,19 +140,6 @@ None use producer default or -1 is infinite. Default: None
 
 number of messages remaining to flush
 
-<a id="quixstreams.kafka.producer.TransactionalProducer"></a>
-
-### TransactionalProducer
-
-```python
-class TransactionalProducer(Producer)
-```
-
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/kafka/producer.py#L184)
-
-A separate producer class used only internally for transactions
-(transactions are only needed when using a consumer).
-
 <a id="quixstreams.kafka.consumer"></a>
 
 ## quixstreams.kafka.consumer