У нас есть кластер kafka с 3 узлами брокеров kafka и 3 серверами zookperes
версия kafka - 10.1 (hortonworks)
насколько я понимаю, так как все метаданные находятся на серверах zookeeper, и брокеры kafka используют эти данные (разговор kafka с сервером zookeeper через порт 2181)
Мне просто интересно, разговаривает ли каждая машина kafka с другой kafka в кластере, или, может быть, kafka получает / помещает данные только на / с серверов zookeepers?
Итак, доза службы кафки должна взаимодействовать с другой кафкой в кластере? , А может машины кафки получают все, что нужно, только с сервера zookeepers?
Брокеры Kafka должны иметь возможность общаться друг с другом.
Zookeeper используется только для метаданных (регистрация брокера, темы, разделы, выборы лидера), сообщения реплицируются напрямую между брокерами Kafka.