Как я могу уменьшить задержку потребителя в 1 секунду в учебнике Kafka?

Question

Я прорабатываю самый первый раздел руководств по Confluent: https://kafka-tutorials.confluent.io/kafka-console-consumer-producer-basics/kafka.html. Все работает, как описано, но я заметил задержку примерно в 1 секунду между нажатием клавиши ввода в терминале производителя и отображением сообщения в терминале потребителя. Ответственность за эту задержку / дозирование несет производитель или потребитель? Есть ли способ настроить вещи, чтобы они были более отзывчивыми? Быстрый поиск показал настройку linger.ms, но похоже, что в последних версиях Kafka этот параметр по умолчанию равен нулю, и, похоже, он не переопределяется в этих контейнерах.

Answer 1

Ладно, похоже установка --timeout=0 в производителе заставляет пропадать лаг. Глядя на исходный код kafka-console-producer, , --timeout по умолчанию 1000 и объединяется в LINGER_MS_CONFIG. Таким образом, несмотря на то, что linger по умолчанию в Kafka обычно равен нулю, в этом производителе командной строки фактически по умолчанию используется 1 se c.