[FLINK-27137] Remove usage of AdminClient from KafkaSource logic

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Won't Do
• Affects Version/s: 1.14.4, 1.15.0
• Component/s: Connectors / Kafka
• Assignee: Unassigned
• Reporter: Gyula Fora
• Created: 08/Apr/22 09:47
• Updated: 09/Apr/22 07:27
• Resolved: 09/Apr/22 07:06

Description

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.