package mz_storage_types.sources.kafka

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: ProtoKafkaMetadataKind

• string key = 1

• bool use_bytes = 2

Used in: ProtoKafkaSourceConnection, ProtoKafkaSourceExportDetails

• string name = 1

• optional ProtoKafkaMetadataKind kind = 2

Used in: ProtoKafkaMetadataColumn

• oneof kind

  • google.protobuf.Empty partition = 1

  • google.protobuf.Empty offset = 2

  • google.protobuf.Empty timestamp = 3

  • google.protobuf.Empty headers = 4

  • ProtoKafkaHeader header = 5

Used in: ProtoSourceConnection

• optional connections.ProtoKafkaConnection connection = 1

• optional mz_repr.catalog_item_id.ProtoCatalogItemId connection_id = 13

• string topic = 2

• map<int32, int64> start_offsets = 3

• optional string group_id_prefix = 4

• repeated ProtoKafkaMetadataColumn metadata_columns = 11

• optional mz_proto.ProtoDuration topic_metadata_refresh_interval = 15

Used in: ProtoSourceExportDetails

• repeated ProtoKafkaMetadataColumn metadata_columns = 1

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

Used in: ProtoSourceExportStatementDetails

(message has no fields)