User-defined codecs from 10000 to 19999.

Metering based on actual consumption.

Metering based on resource reservation.

Use default.

Enum value maps for Codec.

Enum value maps for Codec.

Enum value maps for MeteringMode.

Enum value maps for MeteringMode.

Enum value maps for StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason.

Enum value maps for StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason.

Consumer alter description.

Partitioning settings for topic.

Update existing topic request sent from client to server.

Update topic response sent from server to client.

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

Commit offset request sent from client to server.

Commit offset response sent from server to client.

Commit offset result message inside CommitOffsetResponse.operation.

Consumer description.

Create topic request sent from client to server.

Create topic response sent from server to client.

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

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

Describe topic's consumer response sent from server to client.

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

Describe topic request sent from client to server.

Describe topic response sent from server to client.

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

Drop topic request sent from client to server.

Drop topic response sent from server to client.

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

message representing statistics by seleveral windows.

Represents range [start, end).

Partitioning settings for topic.

Messages for bidirectional streaming rpc StreamRead.

Signal for server that client processed some read data.

Message that is used for describing commit.

Acknowledgement for commits.

Per-partition commit representation.

Client-server message for read session.

Server-client message for read session.

Handshake request.

Handshake response.

Within a StreamRead session delivered messages are separated by partition.

Response for status request.

Message that represents client readiness for receiving more data.

Data read.

Representation of sequence of client messages from one write session.

One client message representation.

Representation of sequence of messages from one partition.

Command from server to create and start a partition session.

Signal for server that cient is ready to recive data for partition.

Command from server to stop and destroy concrete partition session.

Signal for server that client finished working with this partition.

Messages for bidirectional streaming rpc StreamWrite.

Client-server message for write session.

Server-client message for write session.

Handshake request that must be sent to server first.

Response for handshake.

Represents portion of client messages.

Message that represents acknowledgment for sequence of client messages.

Acknowledgment for one persistently written message.

Message with write statistics.

Description of supported codecs.

Add offsets to transaction request sent from client to server.

Add offsets to transaction response sent from server to client.

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

In-session reauthentication and reauthorization, lets user increase session lifetime.

Metering mode specifies the method used to determine consumption of resources by the topic.