public interface InitialPublishRequestOrBuilder extends MessageOrBuilderImplements
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. |