Skip to content

CatalogKafkaSource

Source code in docs_src/capo_glue/types/catalog_kafka_source.py 
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
class CatalogKafkaSource(TypedDict, closed=True):
    name: "capo_glue.types.node_name.NodeName"
    """<p>The name of the data store.</p>"""
    window_size: NotRequired["capo_glue.types.boxed_positive_int.BoxedPositiveInt"]
    """<p>The amount of time to spend processing each micro batch.</p>"""
    detect_schema: NotRequired["capo_glue.types.boxed_boolean.BoxedBoolean"]
    """<p>Whether to automatically determine the schema from the incoming data.</p>"""
    table: "capo_glue.types.enclosed_in_string_property.EnclosedInStringProperty"
    """<p>The name of the table in the database to read from.</p>"""
    database: "capo_glue.types.enclosed_in_string_property.EnclosedInStringProperty"
    """<p>The name of the database to read from.</p>"""
    streaming_options: NotRequired[
        "capo_glue.types.kafka_streaming_source_options.KafkaStreamingSourceOptions"
    ]
    """<p>Specifies the streaming options.</p>"""
    data_preview_options: NotRequired[
        "capo_glue.types.streaming_data_preview_options.StreamingDataPreviewOptions"
    ]
    """<p>Specifies options related to data preview for viewing a sample of your data.</p>"""

data_preview_options instance-attribute 

data_preview_options: NotRequired[StreamingDataPreviewOptions]

Specifies options related to data preview for viewing a sample of your data.

database instance-attribute 

database: EnclosedInStringProperty

The name of the database to read from.

detect_schema instance-attribute 

detect_schema: NotRequired[BoxedBoolean]

Whether to automatically determine the schema from the incoming data.

name instance-attribute 

name: NodeName

The name of the data store.

streaming_options instance-attribute 

streaming_options: NotRequired[KafkaStreamingSourceOptions]

Specifies the streaming options.

table instance-attribute 

table: EnclosedInStringProperty

The name of the table in the database to read from.

window_size instance-attribute 

window_size: NotRequired[BoxedPositiveInt]

The amount of time to spend processing each micro batch.