public static interface PulsarApi.MessageMetadataOrBuilder
extends org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder
boolean hasProducerName()
String getProducerName()
boolean hasSequenceId()
long getSequenceId()
boolean hasPublishTime()
long getPublishTime()
List<PulsarApi.KeyValue> getPropertiesList()
PulsarApi.KeyValue getProperties(int index)
int getPropertiesCount()
boolean hasReplicatedFrom()
String getReplicatedFrom()
boolean hasPartitionKey()
String getPartitionKey()
int getReplicateToCount()
String getReplicateTo(int index)
boolean hasCompression()
PulsarApi.CompressionType getCompression()
boolean hasUncompressedSize()
int getUncompressedSize()
boolean hasNumMessagesInBatch()
int getNumMessagesInBatch()
boolean hasEventTime()
long getEventTime()
List<PulsarApi.EncryptionKeys> getEncryptionKeysList()
PulsarApi.EncryptionKeys getEncryptionKeys(int index)
int getEncryptionKeysCount()
boolean hasEncryptionAlgo()
String getEncryptionAlgo()
boolean hasEncryptionParam()
org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString getEncryptionParam()
boolean hasSchemaVersion()
org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString getSchemaVersion()
boolean hasPartitionKeyB64Encoded()
boolean getPartitionKeyB64Encoded()
Copyright © 2017–2018 Apache Software Foundation. All rights reserved.