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 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.
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.