Module topic

Modules

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_direct_read_message

Nested message and enum types in StreamDirectReadMessage.

stream_read_message

Nested message and enum types in StreamReadMessage.

stream_write_message

Nested message and enum types in StreamWriteMessage.

update_offsets_in_transaction_request

Nested message and enum types in UpdateOffsetsInTransactionRequest.

v1

Structs

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.

CommitOffsetRequest

Commit offset request sent from client to server.

CommitOffsetResponse

Commit offset response sent from server to client.

CommitOffsetResult

Commit offset result message inside CommitOffsetResponse.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.

DescribePartitionRequest

Describe partition request sent from client to server.

DescribePartitionResponse

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

DescribePartitionResult

Describe partition result message that will be inside DescribeTopicResponse.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.

MetadataItem

MultipleWindowsStat

message representing statistics by several windows

OffsetsRange

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

PartitionLocation

Topic partition location

PartitionStats

PartitionWithGeneration

PartitioningSettings

Partitioning settings for topic.

StreamDirectReadMessage

Messages for bidirectional streaming rpc StreamDirectRead

StreamReadMessage

Messages for bidirectional streaming rpc StreamRead

StreamWriteMessage

Messages for bidirectional streaming rpc StreamWrite

SupportedCodecs

Description of supported codecs.

TransactionIdentity

UpdateOffsetsInTransactionRequest

Add offsets to transaction request sent from client to server.

UpdateOffsetsInTransactionResponse

Add offsets to transaction response sent from server to client.

UpdateOffsetsInTransactionResult

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

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.