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
AddOffsetsToTransactionResponse.operation.
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.
Consumer description.
Create topic request sent from client to server.
Create topic response sent from server to client.
If topic is already exists then response status will be “ALREADY_EXISTS”.
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.
If topic is not existed then response status will be “SCHEME_ERROR”.
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.
If topic is not existed then response status will be “SCHEME_ERROR”.
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.
If topic not exists then response status will be “SCHEME_ERROR”.
Drop topic result message that will be inside DropTopicResponse.operation.
message representing statistics by seleveral windows
Represents range [start, end).
I.e. (end - 1) is the greatest of offsets, included in non-empty range.
Partitioning settings for topic.
Messages for bidirectional streaming rpc StreamRead
Messages for bidirectional streaming rpc StreamWrite
Description of supported codecs.
In-session reauthentication and reauthorization, lets user increase session
lifetime. Client should wait for UpdateTokenResponse before sending next
UpdateTokenRequest.