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)

Reply via email to