构建了一个kafka消费组，然后主要是想获取kafka的partition的开始offset 和结束的offset,但是获取的时候这里再某些环境下这里卡死了。

程序如下

    private Map<TopicPartition, Long> getEdnOffsets(KafkaConsumer<String, String> consumer, Collection<