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)