小编gsc*_*441的帖子

我想从服务器的主题开始获取所有消息。

前任：

bin/kafka-console-consumer.sh --zookeeper 本地主机：2181 --topic testTopic --from-beginning

使用上述控制台命令时，我希望能够从一开始就获取主题中的所有消息，但我无法使用 java 代码从一开始就使用主题中的所有消息。

Kafka 服务器轮询消费者/客户端（在 KAFKA 0.10.0.0 中）是否有任何替代方案？

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("foo", "bar"));   
while (true) {  
    ConsumerRecords<String, String> records = consumer.poll(100);  
    for (ConsumerRecord<String, String> record : records)  
        System.out.printf("offset = %d, key = %s, value = %s", record.offset(), record.key(), record.value());  
 }