Skip to content

RecordConfiguration

Source code in docs_src/capo_kinesis/types/record_configuration.py 
14
15
16
17
18
class RecordConfiguration(TypedDict, closed=True):
    record_format_type: "capo_kinesis.types.record_format_type.RecordFormatType"
    """<p>The format of records on the source stream. Valid values:</p> <ul> <li> <p> <code>GSR_JSON</code> - Supported only for streaming table (Amazon S3 Tables) destinations.</p> </li> <li> <p> <code>JSON</code> - Supported for both general purpose Amazon S3 and streaming table destinations.</p> </li> <li> <p> <code>STRING</code> - Supported only for general purpose Amazon S3 destinations.</p> </li> <li> <p> <code>BYTE_ARRAY</code> - Supported only for general purpose Amazon S3 destinations.</p> </li> </ul>"""
    gsr_schema_arn: NotRequired["capo_kinesis.types.gsr_schema_arn.GSRSchemaARN"]
    """<p>The Amazon Resource Name (ARN) of the Amazon Web Services Glue Schema Registry schema used to validate records. Required when the channel destination is a streaming table.</p>"""

gsr_schema_arn instance-attribute 

gsr_schema_arn: NotRequired[GSRSchemaARN]

The Amazon Resource Name (ARN) of the Amazon Web Services Glue Schema Registry schema used to validate records. Required when the channel destination is a streaming table.

record_format_type instance-attribute 

record_format_type: RecordFormatType

The format of records on the source stream. Valid values:

  • GSR_JSON - Supported only for streaming table (Amazon S3 Tables) destinations.

  • JSON - Supported for both general purpose Amazon S3 and streaming table destinations.

  • STRING - Supported only for general purpose Amazon S3 destinations.

  • BYTE_ARRAY - Supported only for general purpose Amazon S3 destinations.