Interface InitialPublishRequestOrBuilder
-
- All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder
- All Known Implementing Classes:
InitialPublishRequest,InitialPublishRequest.Builder
public interface InitialPublishRequestOrBuilder extends com.google.protobuf.MessageOrBuilder
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description com.google.protobuf.ByteStringgetClientId()Unique identifier for a publisher client.longgetPartition()The partition within the topic to which messages will be written.StringgetTopic()The topic to which messages will be written.com.google.protobuf.ByteStringgetTopicBytes()The topic to which messages will be written.-
Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
-
-
-
Method Detail
-
getTopic
String getTopic()
The topic to which messages will be written.
string topic = 1;- Returns:
- The topic.
-
getTopicBytes
com.google.protobuf.ByteString getTopicBytes()
The topic to which messages will be written.
string topic = 1;- Returns:
- The bytes for topic.
-
getPartition
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:
- The partition.
-
getClientId
com.google.protobuf.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:
- The clientId.
-
-