flink new source api， kafka部分对kafka-client的版本要求。

Wed, 10 Nov 2021 23:22:42 -0800 

如题，当前新的kafaksouce貌似对kafka-client版本做了依赖，比如代码KafkaPartitionSplitReader.acquireAndSetStoppingOffsets方法中用到的

consumer.committed(partitionsStoppingAtCommitted)
        .forEach(
                (tp, offsetAndMetadata) -> {
                    Preconditions.checkNotNull(
                            offsetAndMetadata,
                            String.format(
                                    "Partition %s should stop at
committed offset. "
                                            + "But there is no
committed offset of this partition for group %s",
                                    tp, groupId));
                    stoppingOffsets.put(tp, offsetAndMetadata.offset());
                });

在kafka-client2.2.0中是不符合语法的。committed方法签名不同。

回复