apache-kafka - 如何减少 Kafka 教程中的 1s 消费者延迟？

Question

我正在阅读 Confluent 教程的第一部分：https ://kafka-tutorials.confluent.io/kafka-console-consumer-producer-basics/kafka.html 。一切都按描述进行，但我注意到在生产者终端中按 enter 与消费者终端中显示消息之间大约有 1 秒的延迟。是生产者还是消费者对这种滞后/批处理负责？有没有办法将事情配置为更具响应性？快速搜索发现了该linger.ms设置，但似乎最新版本的 Kafka 将此设置默认为零，并且在这些容器中似乎没有被覆盖。

标签： apache-kafka

Answer 1

好的，看起来--timeout=0在生产者中的设置使滞后消失了。查看kafka-console-producer源代码，--timeout默认为 1000 并被合并到LINGER_MS_CONFIG. 因此，即使 Kafka 中的 linger 通常默认为零，但在此命令行生产者中它实际上默认为 1 秒。