@PublicEvolving public class PulsarMessage<T> extends Object
TypedMessageBuilder
. We create this class because
the Pulsar lacks such kind of POJO class.Modifier and Type | Method and Description |
---|---|
long |
getEventTime() |
String |
getKey() |
byte[] |
getOrderingKey() |
Map<String,String> |
getProperties() |
List<String> |
getReplicationClusters() |
org.apache.pulsar.client.api.Schema<T> |
getSchema() |
Long |
getSequenceId() |
T |
getValue() |
boolean |
isDisableReplication() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.