Class | Description |
---|---|
TopicMetadataListener |
We need the latest topic metadata for making sure the newly created topic partitions would be
used by the Pulsar sink.
|
TopicProducerRegister |
All the Pulsar Producers share the same Client, but self hold the queue for a specified topic.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.