Потребитель Kafka Постоянно отправляет TCP-пакеты на сервер Kafka

Question

У нас есть потребитель Kafka, который отлично принимает сообщения. Но дело в том, что когда потребитель Kafka начал свою работу, он отправляет много пакетов TCP в Kafka Broker. Я могу понюхать эти пакеты, используя Wireshark.

Наше понимание Команды такое: он должен отправлять TCP-пакет всякий раз, когда сообщение создается Производителем, и Потребитель должен иметь возможность использовать эти сообщения, отправляя запрос Брокеру. (Как и Event Driven)

Мы не можем по-настоящему понять, почему TCP-пакеты передаются между Брокером и Потребителем непрерывно, когда потребитель начинает работу.

Answer 1

Кафка работает как система, основанная на потоке , взаимодействующая по TCP. Вот почему потребители постоянно отправляют TCP-запросы (запрос poll () и тактовые импульсы). Вы можете проверить эту ссылку для получения дополнительной информации об этом дизайнерском решении Kafka.