@Internal public class TopicMetadataListener extends Object implements Serializable, Closeable
Constructor and Description |
---|
TopicMetadataListener() |
TopicMetadataListener(List<String> topics) |
Modifier and Type | Method and Description |
---|---|
List<String> |
availableTopics()
Return all the available topic partitions.
|
void |
close() |
void |
open(SinkConfiguration sinkConfiguration,
ProcessingTimeService timeService)
Register the topic metadata update in process time service.
|
public void open(SinkConfiguration sinkConfiguration, ProcessingTimeService timeService)
public List<String> availableTopics()
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.