我需要能够消费从一个主题的所有消息，从一开始。基本上与此stackoverflow查询相同，但已为kafka 0.9更新(似乎只有相对较少的0.9特定答案）。
kafka高级使用者使用JavaAPI从主题获取所有消息（相当于--从头开始）
0.9有一个完全不同的api，我真的不知道从哪里开始。我可以使用提供的bash脚本从命令行执行此操作，但不知道如何继续。
你能给我提供一个合适的方法或一个小样本脚本让我开始吗？谢谢您！
我需要能够消费从一个主题的所有消息，从一开始。基本上与此stackoverflow查询相同，但已为kafka 0.9更新(似乎只有相对较少的0.9特定答案）。
kafka高级使用者使用JavaAPI从主题获取所有消息（相当于--从头开始）
0.9有一个完全不同的api，我真的不知道从哪里开始。我可以使用提供的bash脚本从命令行执行此操作，但不知道如何继续。
你能给我提供一个合适的方法或一个小样本脚本让我开始吗？谢谢您！
1条答案
按热度按时间ia2d9nvy1#
你需要设置
auto.offset.reset至earliest. 看到了吗https://kafka.apache.org/documentation.html#newconsumerconfigs另请参见https://github.com/apache/kafka/blob/0.9.0/core/src/main/scala/kafka/tools/consoleconsumer.scala#l179