Skip to content

TopicConfiguration

Source code in docs_src/capo_kafka/types/topic_configuration.py 
13
14
15
16
17
18
19
class TopicConfiguration(TypedDict, closed=True):
    record_converter: NotRequired["capo_kafka.types.record_converter.RecordConverter"]
    """<p>Configuration that controls how Apache Kafka record values are deserialized for the destination.</p>"""
    record_schema: NotRequired["capo_kafka.types.record_schema.RecordSchema"]
    """<p>The schema used to validate records when the value converter requires one (for example, JSON_SCHEMA_GSR).</p>"""
    topic_arn: NotRequired["capo_kafka.types.__string.__string"]
    """<p>The Amazon Resource Name (ARN) that uniquely identifies the topic.</p>"""

record_converter instance-attribute 

record_converter: NotRequired[RecordConverter]

Configuration that controls how Apache Kafka record values are deserialized for the destination.

record_schema instance-attribute 

record_schema: NotRequired[RecordSchema]

The schema used to validate records when the value converter requires one (for example, JSON_SCHEMA_GSR).

topic_arn instance-attribute 

topic_arn: NotRequired[__string]

The Amazon Resource Name (ARN) that uniquely identifies the topic.