[ 
https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519514#comment-17519514
 ] 

Arvid Heise commented on FLINK-27137:
-------------------------------------

Can you please elaborate on {{In some environments using the AdminClient can be 
problematic even if we are not using certaing features.}} 

There are some pros to using the AdminClient and the drawbacks have not been 
clearly stated, so I'd be inclined to close this ticket with "Won't Do".

After you have stated your concerns clearly, I'd probably go for a hybrid 
approach, where a newly introduced {{OffsetRetriever}} abstracts from the used 
client to serve both use cases.

> 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.15.0, 1.14.4
>            Reporter: Gyula Fora
>            Priority: Critical
>
> 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)

Reply via email to