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

如题，当前新的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()); });*来自志愿者整理的flink邮件归档