Module kafka

Source
Expand description

Types related kafka sources

Modules§

proto_kafka_metadata_kind
Nested message and enum types in ProtoKafkaMetadataKind.

Structs§

KafkaSourceConnection
KafkaSourceExportDetails
The details of a source export from a kafka source.
ProtoKafkaHeader
ProtoKafkaMetadataColumn
ProtoKafkaMetadataKind
ProtoKafkaSourceConnection
ProtoKafkaSourceExportDetails
ProtoKafkaSourceExportStatementDetails
NOTE: this message is encoded and stored as part of source export statement options Be extra careful about changes, ensuring that all changes are backwards compatible

Enums§

BoundKind
KafkaMetadataKind
Which piece of metadata a column corresponds to
RangeBound
Given an ordered type P it augments each of its values with a point right before that value, exactly at that value, and right after that value. Additionally, it provides two special values for positive and negative infinity that are greater than and less than all the other elements respectively.

Statics§

KAFKA_PROGRESS_DESC

Functions§

kafka_metadata_columns_desc
Return the column types used to describe the metadata columns of a kafka source export.

Type Aliases§

KafkaTimestamp
A “moment in time” perceivable in Kafka––for each partition, the greatest visible offset.