Gyula Fora created FLINK-27137:
----------------------------------
Summary: Remove usage of AdminClient from KafkaSource logic
Key: FLINK-27137
URL: https://issues.apache.org/jira/browse/FLINK-27137
Project: Flink
Issue Type: Improvement
Components: Connectors / Kafka
Affects Versions: 1.14.4, 1.15.0
Reporter: Gyula Fora
Parts of the KafkaSource logic (specifically the KafkaSourceEnumerator) uses
the Kafka AdminClient instead of the KafkaConsumer.
It seems that the KafkaConsumer already provides all the necessary information
that the enumerator needs so there is no reason for introducing the AdminClient.
In some environments using the AdminClient can be problematic even if we are
not using certaing features.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
