如何从kafka服务器获取主题中的所有消息

Question

我想要从服务器的一个主题开始所有的消息。

当使用上面的控制台命令时，我希望能够从一开始就获得一个主题中的所有消息，但我不能从一开始就使用java代码消费一个主题中的所有消息。

Answer 1

最简单的方法是启动一个消费者并排出所有消息。现在我不知道你的主题中有多少分区，你是否已经有一个现有的消费者组，但你有几个选择：

看看这个API:https://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/kafkaConsumer.html

1）如果同一使用者组中已有一个使用者，但仍想从头开始消费，则应使用API文档中列出的seek选项，并将该组中每个使用者的偏移量设置为0。这将从头开始消费。

2）否则，您可以在一个新的消费群体中建立几个消费者&您就不必担心Seek了。

PS：如果你有更多关于Kafaka的问题，请记得在以后提供更多关于你的设置的细节。很多事情取决于您如何配置您的基础结构&您希望它是怎样的，因此会因情况而异。