Apache Kafka 0.9 Java API 从主题开始消费所有消息
Apache Kafka 0.9 Java API Consuming all messages from beginning of topic
我需要能够从一开始就使用主题中的所有消息。本质上与这个 Whosebug 查询相同，但针对 Kafka 0.9 进行了更新。 （0.9 特定的 Whosebug 答案似乎相对较少）。
Kafka High Level Consumer Fetch All Messages From Topic Using Java API (Equivalent to --from-beginning)
0.9 有一个完全不同的 API，我真的不知道从哪里开始。我可以使用提供的 bash 脚本从命令行执行此操作，但不知道如何继续。
能否请您提供适当的方法或一个小示例脚本让我开始？谢谢！
您需要将 auto.offset.reset 设置为 earliest。参见 https://kafka.apache.org/documentation.html#newconsumerconfigs
我需要能够从一开始就使用主题中的所有消息。本质上与这个 Whosebug 查询相同，但针对 Kafka 0.9 进行了更新。 （0.9 特定的 Whosebug 答案似乎相对较少）。
Kafka High Level Consumer Fetch All Messages From Topic Using Java API (Equivalent to --from-beginning)
0.9 有一个完全不同的 API，我真的不知道从哪里开始。我可以使用提供的 bash 脚本从命令行执行此操作，但不知道如何继续。
能否请您提供适当的方法或一个小示例脚本让我开始？谢谢！
您需要将 auto.offset.reset 设置为 earliest。参见 https://kafka.apache.org/documentation.html#newconsumerconfigs