internalAddGeneratedFile( ' �e protos/ydb_topic.proto Ydb.Topicprotos/ydb_scheme.protoprotos/ydb_status_codes.protoprotos/ydb_issue_message.protoprotos/ydb_table.proto#protos/annotations/validation.protogoogle/protobuf/duration.protogoogle/protobuf/timestamp.proto"7 SupportedCodecs$ codecs
(B��* [1; 19999]��*d"* OffsetsRange start

( end
("# UpdateTokenRequest token

( " UpdateTokenResponse"� StreamWriteMessage�
FromClientA init_request

(2).Ydb.Topic.StreamWriteMessage.InitRequestHC write_request
(2*.Ydb.Topic.StreamWriteMessage.WriteRequestH= update_token_request
(2.Ydb.Topic.UpdateTokenRequestHB client_message� FromServer) status

(2.Ydb.StatusIds.StatusCode\' issues (2.Ydb.Issue.IssueMessageC init_response
(2*.Ydb.Topic.StreamWriteMessage.InitResponseHE write_response
(2+.Ydb.Topic.StreamWriteMessage.WriteResponseH? update_token_response
(2.Ydb.Topic.UpdateTokenResponseHB server_message� InitRequest path

(  producer_id
( [ write_session_meta (2?.Ydb.Topic.StreamWriteMessage.InitRequest.WriteSessionMetaEntry message_group_id
( H partition_id
(H get_last_seq_no
(7 WriteSessionMetaEntry key

(  value
( :8
B partitioning�
InitResponse last_seq_no

( session_id
(  partition_id
(4 supported_codecs
(2.Ydb.Topic.SupportedCodecs� WriteRequestH messages
(26.Ydb.Topic.StreamWriteMessage.WriteRequest.MessageData codec
(�
MessageData seq_no

(. created_at
(2.google.protobuf.Timestamp data
( uncompressed_size
( message_group_id
( H partition_id
(HB partitioning� WriteResponseB acks
(24.Ydb.Topic.StreamWriteMessage.WriteResponse.WriteAck partition_id
(U write_statistics
(2;.Ydb.Topic.StreamWriteMessage.WriteResponse.WriteStatistics� WriteAck seq_no

(O written
(2<.Ydb.Topic.StreamWriteMessage.WriteResponse.WriteAck.WrittenHO skipped
(2<.Ydb.Topic.StreamWriteMessage.WriteResponse.WriteAck.SkippedH Written offset

(�
SkippedS reason

(2C.Ydb.Topic.StreamWriteMessage.WriteResponse.WriteAck.Skipped.Reason"< Reason REASON_UNSPECIFIED REASON_ALREADY_WRITTEN
B message_write_status� WriteStatistics2 persisting_time

(2.google.protobuf.Duration6 min_queue_wait_time
(2.google.protobuf.Duration6 max_queue_wait_time
(2.google.protobuf.Duration< partition_quota_wait_time
(2.google.protobuf.Duration8 topic_quota_wait_time
(2.google.protobuf.Duration"� StreamReadMessageT PartitionSession partition_session_id

( path
(  partition_id
(� FromClient@ init_request

(2(.Ydb.Topic.StreamReadMessage.InitRequestH@ read_request
(2(.Ydb.Topic.StreamReadMessage.ReadRequestHQ commit_offset_request
(20.Ydb.Topic.StreamReadMessage.CommitOffsetRequestHf partition_session_status_request
(2:.Ydb.Topic.StreamReadMessage.PartitionSessionStatusRequestH= update_token_request
(2.Ydb.Topic.UpdateTokenRequestHf start_partition_session_response
(2:.Ydb.Topic.StreamReadMessage.StartPartitionSessionResponseHd stop_partition_session_response
(29.Ydb.Topic.StreamReadMessage.StopPartitionSessionResponseHB client_message� FromServer) status

(2.Ydb.StatusIds.StatusCode\' issues (2.Ydb.Issue.IssueMessageB init_response
(2).Ydb.Topic.StreamReadMessage.InitResponseHB read_response
(2).Ydb.Topic.StreamReadMessage.ReadResponseHS commit_offset_response
(21.Ydb.Topic.StreamReadMessage.CommitOffsetResponseHh !partition_session_status_response
(2;.Ydb.Topic.StreamReadMessage.PartitionSessionStatusResponseH? update_token_response
(2.Ydb.Topic.UpdateTokenResponseHd start_partition_session_request
(29.Ydb.Topic.StreamReadMessage.StartPartitionSessionRequestHb stop_partition_session_request
(28.Ydb.Topic.StreamReadMessage.StopPartitionSessionRequestHB server_message� InitRequestX topics_read_settings
(2:.Ydb.Topic.StreamReadMessage.InitRequest.TopicReadSettings consumer
(  reader_name
( �
TopicReadSettings path

(  partition_ids (* max_lag
(2.google.protobuf.Duration- read_from
(2.google.protobuf.Timestamp" InitResponse session_id

( ! ReadRequest bytes_size

(� ReadResponseO partition_data
(27.Ydb.Topic.StreamReadMessage.ReadResponse.PartitionData bytes_size
(�
MessageData offset

( seq_no
(. created_at
(2.google.protobuf.Timestamp data
( uncompressed_size
( message_group_id
( � BatchK message_data
(25.Ydb.Topic.StreamReadMessage.ReadResponse.MessageData producer_id
( a write_session_meta (2E.Ydb.Topic.StreamReadMessage.ReadResponse.Batch.WriteSessionMetaEntry codec
(. written_at
(2.google.protobuf.Timestamp7 WriteSessionMetaEntry key

(  value
( :8
o PartitionData partition_session_id

(@ batches (2/.Ydb.Topic.StreamReadMessage.ReadResponse.Batch�
CommitOffsetRequest^ commit_offsets
(2F.Ydb.Topic.StreamReadMessage.CommitOffsetRequest.PartitionCommitOffset_ PartitionCommitOffset partition_session_id

(( offsets (2.Ydb.Topic.OffsetsRange�
CommitOffsetResponsep partitions_committed_offsets
(2J.Ydb.Topic.StreamReadMessage.CommitOffsetResponse.PartitionCommittedOffsetR PartitionCommittedOffset partition_session_id

( committed_offset
(= PartitionSessionStatusRequest partition_session_id

(�
PartitionSessionStatusResponse partition_session_id

(2 partition_offsets
(2.Ydb.Topic.OffsetsRange committed_offset
(= write_time_high_watermark
(2.google.protobuf.Timestamp�
StartPartitionSessionRequestH partition_session

(2-.Ydb.Topic.StreamReadMessage.PartitionSession committed_offset
(2 partition_offsets
(2.Ydb.Topic.OffsetsRange�
StartPartitionSessionResponse partition_session_id

( read_offset
(H�

 commit_offset
(H
�

B _read_offsetB _commit_offsetg StopPartitionSessionRequest partition_session_id

( graceful
( committed_offset
(< StopPartitionSessionResponse partition_session_id

("� AddOffsetsToTransactionRequest9 operation_params

(2.Ydb.Operations.OperationParams session_id
( 1 tx_control
(2.Ydb.Table.TransactionControlF topics (26.Ydb.Topic.AddOffsetsToTransactionRequest.TopicOffsets consumer
( �
TopicOffsets path

( [ partitions (2G.Ydb.Topic.AddOffsetsToTransactionRequest.TopicOffsets.PartitionOffsets\\ PartitionOffsets partition_id

(2 partition_offsets (2.Ydb.Topic.OffsetsRange"O AddOffsetsToTransactionResponse, operation

(2.Ydb.Operations.Operation" AddOffsetsToTransactionResult"L MultipleWindowsStat per_minute

( per_hour
( per_day
("� Consumer name

(  important
(- read_from
(2.google.protobuf.Timestamp4 supported_codecs
(2.Ydb.Topic.SupportedCodecs7 attributes (2#.Ydb.Topic.Consumer.AttributesEntry9 consumer_stats
(2!.Ydb.Topic.Consumer.ConsumerStats1 AttributesEntry key

(  value
( :8
�
ConsumerStatsA min_partitions_last_read_time

(2.google.protobuf.Timestamp4 max_read_time_lag
(2.google.protobuf.Duration5 max_write_time_lag
(2.google.protobuf.Duration2 bytes_read
(2.Ydb.Topic.MultipleWindowsStatJ"� AlterConsumer name

(  set_important
(H�

1 set_read_from
(2.google.protobuf.Timestamp8 set_supported_codecs
(2.Ydb.Topic.SupportedCodecsG alter_attributes (2-.Ydb.Topic.AlterConsumer.AlterAttributesEntry6 AlterAttributesEntry key

(  value
( :8
B _set_importantJ"h PartitioningSettings\' min_active_partitions

(B��*>= 0\' partition_count_limit
(B��*>= 0"�
AlterPartitioningSettings0 set_min_active_partitions

(B��*>= 0H�

0 set_partition_count_limit
(B��*>= 0H
�

B _set_min_active_partitionsB _set_partition_count_limit"� CreateTopicRequest9 operation_params

(2.Ydb.Operations.OperationParams path
( > partitioning_settings
(2.Ydb.Topic.PartitioningSettings3 retention_period
(2.google.protobuf.Duration& retention_storage_mb
(B��*>= 04 supported_codecs
(2.Ydb.Topic.SupportedCodecs8 &partition_write_speed_bytes_per_second
(B��*>= 0- partition_write_burst_bytes
(B��*>= 0A attributes (2-.Ydb.Topic.CreateTopicRequest.AttributesEntry/ consumers (2.Ydb.Topic.ConsumerB��*�. metering_mode
(2.Ydb.Topic.MeteringMode1 AttributesEntry key

(  value
( :8
J"C CreateTopicResponse, operation

(2.Ydb.Operations.Operation" CreateTopicResult"v DescribeTopicRequest9 operation_params

(2.Ydb.Operations.OperationParams path
(  include_stats
("E DescribeTopicResponse, operation

(2.Ydb.Operations.Operation"� DescribeTopicResult self

(2.Ydb.Scheme.Entry> partitioning_settings
(2.Ydb.Topic.PartitioningSettings@ partitions (2,.Ydb.Topic.DescribeTopicResult.PartitionInfo3 retention_period
(2.google.protobuf.Duration retention_storage_mb
(4 supported_codecs
(2.Ydb.Topic.SupportedCodecs. &partition_write_speed_bytes_per_second
(# partition_write_burst_bytes
(B attributes (2..Ydb.Topic.DescribeTopicResult.AttributesEntry& consumers (2.Ydb.Topic.Consumer. metering_mode
(2.Ydb.Topic.MeteringMode> topic_stats
(2).Ydb.Topic.DescribeTopicResult.TopicStats1 AttributesEntry key

(  value
( :8
�
PartitionInfo partition_id

( active
( child_partition_ids ( parent_partition_ids (2 partition_stats
(2.Ydb.Topic.PartitionStats�
TopicStats store_size_bytes

(7 min_last_write_time
(2.google.protobuf.Timestamp5 max_write_time_lag
(2.google.protobuf.Duration5 bytes_written
(2.Ydb.Topic.MultipleWindowsStatJ"�
DescribeConsumerRequest9 operation_params

(2.Ydb.Operations.OperationParams path
(  consumer
(  include_stats
("H DescribeConsumerResponse, operation

(2.Ydb.Operations.Operation"� DescribeConsumerResult self

(2.Ydb.Scheme.Entry% consumer
(2.Ydb.Topic.ConsumerC partitions (2/.Ydb.Topic.DescribeConsumerResult.PartitionInfo� PartitionInfo partition_id

( active
( child_partition_ids ( parent_partition_ids (2 partition_stats
(2.Ydb.Topic.PartitionStatsZ partition_consumer_stats
(28.Ydb.Topic.DescribeConsumerResult.PartitionConsumerStats� PartitionConsumerStats last_read_offset

( committed_offset
( read_session_id
( F "partition_read_session_create_time
(2.google.protobuf.Timestamp2 last_read_time
(2.google.protobuf.Timestamp4 max_read_time_lag
(2.google.protobuf.Duration5 max_write_time_lag
(2.google.protobuf.Duration2 bytes_read
(2.Ydb.Topic.MultipleWindowsStat reader_name
(  connection_node_id
("� PartitionStats2 partition_offsets

(2.Ydb.Topic.OffsetsRange store_size_bytes
(3 last_write_time
(2.google.protobuf.Timestamp5 max_write_time_lag
(2.google.protobuf.Duration5 bytes_written
(2.Ydb.Topic.MultipleWindowsStat partition_node_id
("� AlterTopicRequest9 operation_params

(2.Ydb.Operations.OperationParams path
( I alter_partitioning_settings
(2$.Ydb.Topic.AlterPartitioningSettings7 set_retention_period
(2.google.protobuf.Duration/ set_retention_storage_mb
(B��*>= 0H�

8 set_supported_codecs
(2.Ydb.Topic.SupportedCodecsA *set_partition_write_speed_bytes_per_second
(B��*>= 0H
�

6 set_partition_write_burst_bytes
(B��*>= 0H�

K alter_attributes (21.Ydb.Topic.AlterTopicRequest.AlterAttributesEntry3 add_consumers (2.Ydb.Topic.ConsumerB��*� drop_consumers ( B��*�: alter_consumers (2.Ydb.Topic.AlterConsumerB��*�2 set_metering_mode
(2.Ydb.Topic.MeteringMode6 AlterAttributesEntry key

(  value
( :8
B _set_retention_storage_mbB- +_set_partition_write_speed_bytes_per_secondB" _set_partition_write_burst_bytesJ"B AlterTopicResponse, operation

(2.Ydb.Operations.Operation" AlterTopicResult"[ DropTopicRequest9 operation_params

(2.Ydb.Operations.OperationParams path
( "A DropTopicResponse, operation

(2.Ydb.Operations.Operation" DropTopicResult*�
Codec CODEC_UNSPECIFIED CODEC_RAW
 CODEC_GZIP CODEC_LZOP CODEC_ZSTD CODEC_CUSTOM�N"�N" ��
����*s MeteringMode METERING_MODE_UNSPECIFIED# METERING_MODE_RESERVED_CAPACITY
 METERING_MODE_REQUEST_UNITSBM tech.ydb.topicZ8github.com/ydb-platform/ydb-go-genproto/protos/Ydb_Topic�

bproto3' , true); static::$is_initialized = true; } }