Skip to content

IcebergDestinationUpdate

Used by
Source code in docs_src/capo_kafka/types/iceberg_destination_update.py 
11
12
13
class IcebergDestinationUpdate(TypedDict, closed=True):
    data_freshness_in_seconds: NotRequired["capo_kafka.types.__integer.__integer"]
    """<p>The maximum time, in seconds, that records buffer in MSK before being flushed to the destination. Allowed range: 300 to 900.</p>"""

data_freshness_in_seconds instance-attribute 

data_freshness_in_seconds: NotRequired[__integer]

The maximum time, in seconds, that records buffer in MSK before being flushed to the destination. Allowed range: 300 to 900.