我正在学习合流教程的第一部分：https://kafka-tutorials.confluent.io/kafka-console-consumer-producer-basics/kafka.html. 一切都如所描述的那样工作，但是我注意到在生产者终端中按enter键和在消费者终端中显示消息之间有大约1秒的延迟。是生产者还是消费者对延迟/批量负责？有没有一种方法可以让事情变得更具响应性？一个快速的搜索发现了 linger.ms 设置，但最近版本的Kafka似乎将此设置默认为零，并且在这些容器中似乎不会被覆盖。
1条答案
按热度按时间lbsnaicq1#
好的，看起来像是
--timeout=0在生产商使滞后消失。在看kafka-console-producer源代码，--timeout默认为1000并合并到LINGER_MS_CONFIG. 因此，尽管在kafka中，linger通常默认为0，但在这个命令行生成器中，它实际上默认为1秒。