Module mz_storage_types::sources::kafka

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.

Constants

• _IMPL_ARBITRARY_FOR_KafkaMetadataKind 🔒
• _IMPL_ARBITRARY_FOR_KafkaSourceConnection 🔒
• _IMPL_ARBITRARY_FOR_KafkaSourceExportDetails 🔒

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.