Package | Description |
---|---|
org.apache.flink.connector.pulsar.sink.writer |
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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.