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)