Chore/bump version 2.7.0 (#395)

* Bump version to 2.7.0
* Re-generate API docs

Author: daniil-quix

docs/api-reference/application.md

@@ -10,7 +10,7 @@
 class Application()
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/app.py#L55)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/app.py#L56)
 
 The main Application class.
 
@@ -40,7 +40,7 @@ Most functionality is explained the various methods, except for
 ```python
 from quixstreams import Application
 
-# Set up an `app = Application` and  `sdf = StreamingDataFrame`;
+# Set up an `app = Application` and `sdf = StreamingDataFrame`;
 # add some operations to `sdf` and then run everything.
 
 app = Application(broker_address='localhost:9092', consumer_group='group')
@@ -79,10 +79,11 @@ def __init__(broker_address: Optional[Union[str, ConnectionConfig]] = None,
              quix_config_builder: Optional[QuixKafkaConfigsBuilder] = None,
              topic_manager: Optional[TopicManager] = None,
              request_timeout: float = 30,
-             topic_create_timeout: float = 60)
+             topic_create_timeout: float = 60,
+             processing_guarantee: ProcessingGuarantee = "at-least-once")
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/app.py#L93)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/app.py#L94)
 
 
 <br>
@@ -134,6 +135,7 @@ Default - `True`
 - `topic_manager`: A `TopicManager` instance
 - `request_timeout`: timeout (seconds) for REST-based requests
 - `topic_create_timeout`: timeout (seconds) for topic create finalization
+- `processing_guarantee`: Use "exactly-once" or "at-least-once" processing.
 <br><br>***Error Handlers***<br>
 To handle errors, `Application` accepts callbacks triggered when
     exceptions occur on different stages of stream processing. If the callback
@@ -158,29 +160,33 @@ instead of the default one.
 
 ```python
 @classmethod
-def Quix(cls,
-         consumer_group: Optional[str] = None,
-         auto_offset_reset: AutoOffsetReset = "latest",
-         consumer_extra_config: Optional[dict] = None,
-         producer_extra_config: Optional[dict] = None,
-         state_dir: str = "state",
-         rocksdb_options: Optional[RocksDBOptionsType] = None,
-         on_consumer_error: Optional[ConsumerErrorCallback] = None,
-         on_processing_error: Optional[ProcessingErrorCallback] = None,
-         on_producer_error: Optional[ProducerErrorCallback] = None,
-         on_message_processed: Optional[MessageProcessedCallback] = None,
-         consumer_poll_timeout: float = 1.0,
-         producer_poll_timeout: float = 0.0,
-         loglevel: Optional[LogLevel] = "INFO",
-         quix_config_builder: Optional[QuixKafkaConfigsBuilder] = None,
-         auto_create_topics: bool = True,
-         use_changelog_topics: bool = True,
-         topic_manager: Optional[QuixTopicManager] = None,
-         request_timeout: float = 30,
-         topic_create_timeout: float = 60) -> Self
+def Quix(
+    cls,
+    consumer_group: Optional[str] = None,
+    auto_offset_reset: AutoOffsetReset = "latest",
+    consumer_extra_config: Optional[dict] = None,
+    producer_extra_config: Optional[dict] = None,
+    state_dir: str = "state",
+    rocksdb_options: Optional[RocksDBOptionsType] = None,
+    on_consumer_error: Optional[ConsumerErrorCallback] = None,
+    on_processing_error: Optional[ProcessingErrorCallback] = None,
+    on_producer_error: Optional[ProducerErrorCallback] = None,
+    on_message_processed: Optional[MessageProcessedCallback] = None,
+    consumer_poll_timeout: float = 1.0,
+    producer_poll_timeout: float = 0.0,
+    loglevel: Optional[LogLevel] = "INFO",
+    quix_config_builder: Optional[QuixKafkaConfigsBuilder] = None,
+    auto_create_topics: bool = True,
+    use_changelog_topics: bool = True,
+    topic_manager: Optional[QuixTopicManager] = None,
+    request_timeout: float = 30,
+    topic_create_timeout: float = 60,
+    processing_guarantee: Literal["at-least-once",
+                                  "exactly-once"] = "exactly-once"
+) -> Self
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/app.py#L313)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/app.py#L330)
 
 >***NOTE:*** DEPRECATED: use Application with `quix_sdk_token` argument instead.
 
@@ -253,6 +259,7 @@ Default - `True`
 - `topic_manager`: A `QuixTopicManager` instance
 - `request_timeout`: timeout (seconds) for REST-based requests
 - `topic_create_timeout`: timeout (seconds) for topic create finalization
+- `processing_guarantee`: Use "exactly-once" or "at-least-once" processing.
 <br><br>***Error Handlers***<br>
 To handle errors, `Application` accepts callbacks triggered when
     exceptions occur on different stages of stream processing. If the callback
@@ -290,7 +297,7 @@ def topic(name: str,
           timestamp_extractor: Optional[TimestampExtractor] = None) -> Topic
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/app.py#L451)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/app.py#L471)
 
 Create a topic definition.
 
@@ -371,7 +378,7 @@ topic = app.topic("input-topic", timestamp_extractor=custom_ts_extractor)
 def dataframe(topic: Topic) -> StreamingDataFrame
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/app.py#L531)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/app.py#L551)
 
 A simple helper method that generates a `StreamingDataFrame`, which is used
 
@@ -421,7 +428,7 @@ to be used as an input topic.
 def stop(fail: bool = False)
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/app.py#L570)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/app.py#L590)
 
 Stop the internal poll loop and the message processing.
 
@@ -448,7 +455,7 @@ to unhandled exception, and it shouldn't commit the current checkpoint.
 def get_producer() -> Producer
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/app.py#L593)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/app.py#L613)
 
 Create and return a pre-configured Producer instance.
 The Producer is initialized with params passed to Application.
@@ -483,19 +490,23 @@ with app.get_producer() as producer:
 def get_consumer(auto_commit_enable: bool = True) -> Consumer
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/app.py#L623)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/app.py#L643)
 
 Create and return a pre-configured Consumer instance.
 The Consumer is initialized with params passed to Application.
 
-It's useful for consuming data from Kafka outside the standard Application processing flow.
-(e.g. to consume test data from a topic).
-Using it within the StreamingDataFrame functions is not recommended, as it creates a new Consumer instance
+It's useful for consuming data from Kafka outside the standard
+Application processing flow.
+(e.g., to consume test data from a topic).
+Using it within the StreamingDataFrame functions is not recommended, as it
+creates a new Consumer instance
 each time, which is not optimized for repeated use in a streaming pipeline.
 
-Note: By default this consumer does not autocommit consumed offsets to allow exactly-once processing.
+Note: By default, this consumer does not autocommit the consumed offsets to allow
+at-least-once processing.
 To store the offset call store_offsets() after processing a message.
-If autocommit is necessary set `enable.auto.offset.store` to True in the consumer config when creating the app.
+If autocommit is necessary set `enable.auto.offset.store` to True in
+the consumer config when creating the app.
 
 
 <br>
@@ -528,7 +539,7 @@ with app.get_consumer() as consumer:
 def clear_state()
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/app.py#L666)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/app.py#L690)
 
 Clear the state of the application.
 
@@ -542,7 +553,7 @@ Clear the state of the application.
 def run(dataframe: StreamingDataFrame)
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/app.py#L672)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/app.py#L696)
 
 Start processing data from Kafka using provided `StreamingDataFrame`
 

docs/api-reference/context.md

@@ -12,7 +12,7 @@
 def set_message_context(context: Optional[MessageContext])
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/context.py#L20)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/context.py#L20)
 
 Set a MessageContext for the current message in the given `contextvars.Context`
 
@@ -55,7 +55,7 @@ sdf = sdf.update(lambda value: alter_context(value))
 def message_context() -> MessageContext
 ```
 
-[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/ea3d07177df3f11deb3c51e8337534408f5f68c1/quixstreams/context.py#L51)
+[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/209d74b1262aa6d90dddd1a01473c83d9d10fdce/quixstreams/context.py#L51)
 
 Get a MessageContext for the current message, which houses most of the message