Package | Description |
---|---|
org.apache.flink.connector.pulsar.sink | |
org.apache.flink.connector.pulsar.sink.writer | |
org.apache.flink.connector.pulsar.sink.writer.delayer |
Modifier and Type | Method and Description |
---|---|
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.delaySendingMessage(MessageDelayer<IN> messageDelayer)
Set a message delayer for enable Pulsar message delay delivery.
|
Constructor and Description |
---|
PulsarWriter(SinkConfiguration sinkConfiguration,
PulsarSerializationSchema<IN> serializationSchema,
TopicMetadataListener metadataListener,
TopicRouter<IN> topicRouter,
MessageDelayer<IN> messageDelayer,
Sink.InitContext initContext)
Constructor creating a Pulsar writer.
|
Modifier and Type | Class and Description |
---|---|
class |
FixedMessageDelayer<IN>
A delayer for making sure all the messages would be sent in a fixed delay duration.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.