public interface InitialPublishRequestOrBuilder extends MessageOrBuilder
Implements
MessageOrBuilderMethods
getClientId()
public abstract ByteString getClientId()
Unique identifier for a publisher client. If set, enables publish idempotency within a publisher client session.
The length of this field must be exactly 16 bytes long and should be populated with a 128 bit uuid, generated by standard uuid algorithms like uuid1 or uuid4. The same identifier should be reused following disconnections with retryable stream errors.
bytes client_id = 3;
Returns | |
---|---|
Type | Description |
ByteString |
The clientId. |
getPartition()
public abstract long getPartition()
The partition within the topic to which messages will be written.
Partitions are zero indexed, so partition
must be in the range [0,
topic.num_partitions).
int64 partition = 2;
Returns | |
---|---|
Type | Description |
long |
The partition. |
getTopic()
public abstract String getTopic()
The topic to which messages will be written.
string topic = 1;
Returns | |
---|---|
Type | Description |
String |
The topic. |
getTopicBytes()
public abstract ByteString getTopicBytes()
The topic to which messages will be written.
string topic = 1;
Returns | |
---|---|
Type | Description |
ByteString |
The bytes for topic. |