我正在尝试用 Java 创建一个消费者客户端。我意识到 poll() 函数已贬值。听卡夫卡的话题有哪些选择？
我的代码:
KafkaConsumer< String, UserSegmentPayload > kc = new KafkaConsumer<>(props2);
kc.subscribe(Collections.singletonList(topicName));
while (true) {
ConsumerRecords<String, UserSegmentPayload> records = kc.poll(100);
for (ConsumerRecord<String, UserSegmentPayload> record : records) {
System.out.printf("offset = %d, key = %s, value = %s\n",
record.offset(), record.key(), record.value());
}
}
最佳答案
原因poll()和 poll(long)不推荐使用的是它们可能会无限期地阻塞(即使在第二种情况下，指定了超时)。此行为的根本原因是这些方法中的初始元数据更新可能会永远阻塞(请参阅 here )。相反，您应该使用 poll(Duration) -方法KafkaConsumer .因此，在您的代码中，您所要做的就是替换 kc.poll(100)与 kc.poll(Duration.ofMillis(100)) .
关于java - Kafka - 在 Java 中聆听主题的比 poll() 更好的替代方法是什么？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/59943786/