Module topic

Modules

add_offsets_to_transaction_request

Nested message and enum types in AddOffsetsToTransactionRequest.

consumer

Nested message and enum types in Consumer.

describe_consumer_result

Nested message and enum types in DescribeConsumerResult.

describe_topic_result

Nested message and enum types in DescribeTopicResult.

stream_read_message

Nested message and enum types in StreamReadMessage.

stream_write_message

Nested message and enum types in StreamWriteMessage.

v1

Structs

AddOffsetsToTransactionRequest

Add offsets to transaction request sent from client to server.

AddOffsetsToTransactionResponse

Add offsets to transaction response sent from server to client.

AddOffsetsToTransactionResult

Add offsets to transaction result message that will be inside AddOffsetsToTransactionResponse.operation.

AlterConsumer

Consumer alter description.

AlterPartitioningSettings

Partitioning settings for topic.

AlterTopicRequest

Update existing topic request sent from client to server.

AlterTopicResponse

Update topic response sent from server to client.

AlterTopicResult

Update topic result message that will be inside UpdateTopicResponse.operation.

Consumer

Consumer description.

CreateTopicRequest

Create topic request sent from client to server.

CreateTopicResponse

Create topic response sent from server to client. If topic is already exists then response status will be “ALREADY_EXISTS”.

CreateTopicResult

Create topic result message that will be inside CreateTopicResponse.operation.

DescribeConsumerRequest

Describe topic’s consumer request sent from client to server.

DescribeConsumerResponse

Describe topic’s consumer response sent from server to client. If topic is not existed then response status will be “SCHEME_ERROR”.

DescribeConsumerResult

Describe topic’s consumer result message that will be inside DescribeConsumerResponse.operation.

DescribeTopicRequest

Describe topic request sent from client to server.

DescribeTopicResponse

Describe topic response sent from server to client. If topic is not existed then response status will be “SCHEME_ERROR”.

DescribeTopicResult

Describe topic result message that will be inside DescribeTopicResponse.operation.

DropTopicRequest

Drop topic request sent from client to server.

DropTopicResponse

Drop topic response sent from server to client. If topic not exists then response status will be “SCHEME_ERROR”.

DropTopicResult

Drop topic result message that will be inside DropTopicResponse.operation.

MultipleWindowsStat

message representing statistics by seleveral windows

OffsetsRange

Represents range [start, end). I.e. (end - 1) is the greatest of offsets, included in non-empty range.

PartitionStats

PartitioningSettings

Partitioning settings for topic.

StreamReadMessage

Messages for bidirectional streaming rpc StreamRead

StreamWriteMessage

Messages for bidirectional streaming rpc StreamWrite

SupportedCodecs

Description of supported codecs.

UpdateTokenRequest

In-session reauthentication and reauthorization, lets user increase session lifetime. Client should wait for UpdateTokenResponse before sending next UpdateTokenRequest.

UpdateTokenResponse

Enums

Codec

MeteringMode

Metering mode specifies the method used to determine consumption of resources by the topic. This settings will have an effect only in a serverless database.