package mz_storage_types.sinks

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: ProtoKafkaSinkConnectionV2

• oneof kind

  • ProtoKafkaIdStyle.ProtoKafkaIdStylePrefix prefix = 1

  • google.protobuf.Empty legacy = 2

Used in: ProtoKafkaIdStyle

• optional string prefix = 1

Used in: ProtoStorageSinkConnection

• optional mz_repr.catalog_item_id.ProtoCatalogItemId connection_id = 1

• optional connections.ProtoKafkaConnection connection = 2

• string topic = 3

• optional ProtoKafkaSinkConnectionV2.ProtoKeyDescAndIndices key_desc_and_indices = 4

• optional ProtoKafkaSinkConnectionV2.ProtoRelationKeyIndicesVec relation_key_indices = 5

• optional uint64 headers_index = 22

• optional mz_repr.relation_and_scalar.ProtoRelationDesc value_desc = 6

• optional mz_expr.scalar.ProtoMirScalarExpr partition_by = 26

• optional ProtoKafkaSinkFormat format = 11

• oneof compression_type

  • google.protobuf.Empty none = 14

  • google.protobuf.Empty gzip = 15

  • google.protobuf.Empty snappy = 16

  • google.protobuf.Empty lz4 = 17

  • google.protobuf.Empty zstd = 18

• optional ProtoKafkaIdStyle progress_group_id = 19

• optional ProtoKafkaIdStyle transactional_id = 20

• optional connections.ProtoKafkaTopicOptions topic_options = 23

• optional mz_proto.ProtoDuration topic_metadata_refresh_interval = 25

Used in: ProtoKafkaSinkConnectionV2

• optional mz_repr.relation_and_scalar.ProtoRelationDesc desc = 1

• repeated uint64 indices = 2

Used in: ProtoKafkaSinkConnectionV2

• repeated uint64 relation_key_indices = 1

Used in: ProtoKafkaSinkConnectionV2

• optional ProtoKafkaSinkFormatType key_format = 1

• optional ProtoKafkaSinkFormatType value_format = 2

Used in: ProtoKafkaSinkFormat

• oneof type

  • ProtoKafkaSinkFormatType.ProtoKafkaSinkAvroFormat avro = 1

  • google.protobuf.Empty json = 2

  • google.protobuf.Empty text = 3

  • google.protobuf.Empty bytes = 4

Used in: ProtoKafkaSinkFormatType

• string schema = 1

• ProtoKafkaSinkAvroFormat.CompatibilityLevel compatibility_level = 2

• optional connections.ProtoCsrConnection csr_connection = 3

Used in: ProtoKafkaSinkAvroFormat

• UNSET = 0

  Used when this value is Option::None

• BACKWARD = 1

• BACKWARD_TRANSITIVE = 2

• FORWARD = 3

• FORWARD_TRANSITIVE = 4

• FULL = 5

• FULL_TRANSITIVE = 6

• NONE = 7

• optional mz_repr.relation_and_scalar.ProtoRelationDesc value_desc = 1

• optional controller.ProtoCollectionMetadata storage_metadata = 2

Used in: ProtoS3UploadInfo

• oneof kind

  • mz_pgcopy.copy.ProtoCopyFormatParams pg_copy = 1

  • google.protobuf.Empty parquet = 2

Used in: mz_compute_types.sinks.ProtoCopyToS3OneshotSinkConnection

• string uri = 1

• uint64 max_file_size = 2

• optional mz_repr.relation_and_scalar.ProtoRelationDesc desc = 3

• optional ProtoS3SinkFormat format = 4

Used in: ProtoStorageSinkDesc

• oneof kind

  • google.protobuf.Empty debezium = 1

  • google.protobuf.Empty upsert = 2

Used in: ProtoStorageSinkDesc

• oneof kind

  • ProtoKafkaSinkConnectionV2 kafka_v2 = 2

Used in: mz_storage_client.client.ProtoRunSinkCommand

• optional mz_repr.global_id.ProtoGlobalId from = 1

• optional mz_repr.relation_and_scalar.ProtoRelationDesc from_desc = 2

• optional ProtoStorageSinkConnection connection = 3

• optional ProtoSinkEnvelope envelope = 4

• optional controller.ProtoCollectionMetadata from_storage_metadata = 6

• optional controller.ProtoCollectionMetadata to_storage_metadata = 15

• optional mz_repr.antichain.ProtoU64Antichain as_of = 11

• bool with_snapshot = 12

• uint64 version = 13