Package | Description |
---|---|
org.apache.flink.connector.pulsar.sink |
Modifier and Type | Method and Description |
---|---|
static <IN> PulsarSinkBuilder<IN> |
PulsarSink.builder()
Create a
PulsarSinkBuilder to construct a new PulsarSink . |
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.delaySendingMessage(MessageDelayer<IN> messageDelayer)
Set a message delayer for enable Pulsar message delay delivery.
|
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.enableSchemaEvolution()
If you enable this option, we would consume and deserialize the message by using Pulsar
Schema . |
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setAdminUrl(String adminUrl)
Sets the admin endpoint for the PulsarAdmin of the PulsarSink.
|
<T> PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setConfig(ConfigOption<T> key,
T value)
Set an arbitrary property for the PulsarSink and Pulsar Producer.
|
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setConfig(Configuration config)
Set arbitrary properties for the PulsarSink and Pulsar Producer.
|
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setDeliveryGuarantee(DeliveryGuarantee deliveryGuarantee)
Sets the wanted the
DeliveryGuarantee . |
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setProducerName(String producerName)
The producer name is informative, and it can be used to identify a particular producer
instance from the topic stats.
|
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setProperties(Properties properties)
Set arbitrary properties for the PulsarSink and Pulsar Producer.
|
<T extends IN> |
PulsarSinkBuilder.setSerializationSchema(PulsarSerializationSchema<T> serializationSchema)
Sets the
PulsarSerializationSchema that transforms incoming records to bytes. |
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setServiceUrl(String serviceUrl)
Sets the server's link for the PulsarProducer of the PulsarSink.
|
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setTopicRouter(TopicRouter<IN> topicRouter)
Use a custom topic router instead predefine topic routing.
|
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setTopicRoutingMode(TopicRoutingMode topicRoutingMode)
Set a routing mode for choosing right topic partition to send messages.
|
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setTopics(List<String> topics)
Set a pulsar topic list for flink sink.
|
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setTopics(String... topics)
Set a pulsar topic list for flink sink.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.