This class is used to retrieve initial topic(s) related metadata from the cluster. Now that KafkaConsumerOperator has a RdKafka::KafkaConsumer in it, it will simplify things to use this to retrieve the metadata. The Connector class can be dropped and its functionality can be added directly to the parent KafkaConsumerOperator class
- depends on
-
SERVER-93580 support multitopic ingest for kafka sources
- Closed