Package | Description |
---|---|
org.apache.flink.connector.pulsar.sink.writer.message |
Modifier and Type | Method and Description |
---|---|
PulsarMessageBuilder<T> |
PulsarMessageBuilder.disableReplication()
Method wrapper of
TypedMessageBuilder.disableReplication() . |
PulsarMessageBuilder<T> |
PulsarMessageBuilder.eventTime(long eventTime)
Method wrapper of
TypedMessageBuilder.eventTime(long) . |
PulsarMessageBuilder<T> |
PulsarMessageBuilder.key(String key)
Property
TypedMessageBuilder.key(String) . |
PulsarMessageBuilder<T> |
PulsarMessageBuilder.orderingKey(byte[] orderingKey)
Method wrapper of
TypedMessageBuilder.orderingKey(byte[]) . |
PulsarMessageBuilder<T> |
PulsarMessageBuilder.properties(Map<String,String> properties)
Method wrapper of
TypedMessageBuilder.properties(Map) . |
PulsarMessageBuilder<T> |
PulsarMessageBuilder.property(String key,
String value)
Method wrapper of
TypedMessageBuilder.property(String, String) . |
PulsarMessageBuilder<T> |
PulsarMessageBuilder.replicationClusters(List<String> replicationClusters)
Method wrapper of
TypedMessageBuilder.replicationClusters(List) . |
PulsarMessageBuilder<T> |
PulsarMessageBuilder.sequenceId(long sequenceId)
Method wrapper of
TypedMessageBuilder.sequenceId(long) . |
PulsarMessageBuilder<T> |
PulsarMessageBuilder.value(org.apache.pulsar.client.api.Schema<T> schema,
T value)
Method wrapper of
TypedMessageBuilder.value(Object) . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.