我在哪里可以使用 kafka java api 从一个主题中获取所有消息
Where can I get all the message from one topic using kafka java api
在命令行中，我可以使用“--from-beginning”来获取一个主题中的所有消息，但是当我编写一个 java 程序时，我怎么能得到同样的努力，而且我我正在使用高级消费者 api。
在创建消费者属性时您可以添加
props.put("auto.offset.reset", "smallest"); 从头开始阅读
在命令行中，我可以使用“--from-beginning”来获取一个主题中的所有消息，但是当我编写一个 java 程序时，我怎么能得到同样的努力，而且我我正在使用高级消费者 api。
在创建消费者属性时您可以添加
props.put("auto.offset.reset", "smallest"); 从头开始阅读