Конфлюэнтный репликатор не может реплицировать данные на целевой сервер kafka

Question

Я установил конфлюэнтную Kafka на двух разных хостах и ​​пытаюсь заставить конфлюентный репликатор работать. Я выполнил то, что упоминалось в этом уроке .

Я не вижу ошибок при запуске репликатора, и вот журнал, который я вижу:

WorkerSourceTask {id = replicator-source-0} Фиксирование смещений (org.apache.kafka.connect.runtime.WorkerSourceTask: 397) [2019-03-26 06: 38: 15,049] INFO WorkerSourceTask {id = replicator-source-0} сбрасывает 0 ожидающие сообщения для смещения фиксации (Org.apache.kafka.connect.runtime.WorkerSourceTask: 414)

Я попытался запустить репликатор на обоих хостах сервера kafka; Я ожидаю, что репликатор будет реплицировать данные на конечном сервере

Answer 1

Ошибка, которую я сделал, состояла в том, что у меня были исходные значения kafka в connect-standalone.properties. Но это должен быть пункт назначения Кафка.