Недавно я обновил зеркало kafka, и теперь оно не может подключиться к исходным серверам zk - сбой потребителя. Предыдущая версия была основана на java: openjdk-8-jre, kafka_2.11-1.0.2.tgz и zookeeper: 3.4.10. Я обновил kafka до kafka_2.12-2.2.0.tgz,...

Мы настроили Mirror Maker для репликации тем между двумя кластерами kafka, когда настройки источника и назначения различны (источник = 2 сервера, место назначения = 3 сервера). при запуске MirrorMaker выдает следующую ошибку: «Ошибка:...

В настоящее время мы пытаемся перенести репликатор Confluent на Apache Open Source Mirror Maker v2.0. Мы сталкиваемся с проблемой, когда сообщения, которые уже реплицированы репликатором, снова реплицируются, когда создатель зеркала запускается в той...

Предположим, у меня есть приложение Kafka Streams, в котором есть две темы ввода: тема заказов и тема платежей. Платеж относится к конкретному заказу, и приложение будет что-то делать с объединенным заказом и оплатой. Обычно, если мое приложение...