我需要能够从一开始就使用某个主题的所有消息。与此 StackOverflow 查询基本相同，但针对 Kafka 0.9 进行了更新。 (似乎针对 0.9 的 StackOverflow 答案相对较少)。
0.9 有一个完全不同的 API，我真的不知道从哪里开始。我可以使用提供的 bash 脚本从命令行执行此操作，但不知道如何继续。
您能否提供适当的方法或一个小示例脚本来帮助我入门？谢谢!
最佳答案
您需要将auto.offset.reset设置为最早。请参阅https://kafka.apache.org/documentation.html#newconsumerconfigs
关于java - Apache Kafka 0.9 Java API 使用主题开头的所有消息，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/36992894/