All Implemented Interfaces:
Closeable, Serializable, AutoCloseable
public class TopicMetadataListener
implements Serializable, Closeable
We need the latest topic metadata for making sure the newly created topic partitions would be
used by the Pulsar sink. This routing policy would be different compared with Pulsar Client
built-in logic. We use Flink's ProcessingTimer as the executor.
Methods inherited from class java.lang.
Object clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
List< String> availableTopics()
Return all the available topic partitions. We would recalculate the partitions if the topic
metadata has been changed. Otherwise, we would return the cached result for better
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.