qiuyanjun888 commented on PR #282: URL: https://github.com/apache/flink-connector-kafka/pull/282#issuecomment-4953770390
@bowenli86 Thanks for the clarification. I re-investigated the failure and updated this PR to focus on the library compatibility issue in FLINK-39193. The root cause is the direct `ListConsumerGroupOffsetsSpec` reference introduced with the Kafka 4.0 client upgrade. The class and map-based overload are absent in Kafka clients before 3.3, which reproduces the reported `NoClassDefFoundError` when an older client is present at runtime. The PR now uses the long-standing `AdminClient#listConsumerGroupOffsets(String)` overload and filters the returned offsets to the requested partitions. I removed the previous behavior-change approach, so incomplete specified offsets continue to prefer committed offsets before falling back to the configured reset strategy. I also added a focused filtering regression test and verified the relevant API linkage with representative Kafka client JARs from 2.1.1 through 4.2.x. The focused Maven test, checkstyle, and spotless checks pass locally. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
