如何控制消费的位置 ?

kafka 使用 seek(TopicPartition, long)指定新的消费位置用于查找服务器保留 

的最早和最新的 offset 的特殊的方法也可用(seekToBeginning(Collection)  

seekToEnd(Collection))

Java Program!
原文地址:https://www.cnblogs.com/programb/p/12995974.html