You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "dengziming (Jira)" <ji...@apache.org> on 2021/12/18 02:20:00 UTC

[jira] [Created] (FLINK-25368) Use AdminClient to get offsets rather than KafkaConsumer

dengziming created FLINK-25368:
----------------------------------

             Summary: Use AdminClient to get offsets rather than KafkaConsumer
                 Key: FLINK-25368
                 URL: https://issues.apache.org/jira/browse/FLINK-25368
             Project: Flink
          Issue Type: Improvement
            Reporter: dengziming


`AdminClient.listOffsets` is provided in Kafka 2.7, In the future more `OffsetSpce` types will be added to it, for example, OffsetSpec.MaxTimestampSpec is added in Kafka 3.0. so it's better to substitute `KafkaConsumer` with `AdminClient`.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)