Я использую Kafka Connect для разных целей, и он работает нормально.Это скорее вопрос любопытства.Попытка выяснить, читая код, может занять некоторое время, поэтому я спрашиваю здесь .. (но я все равно попробую прочитать код Кафки ..)
Я знаю, что Соединитель - тот, кто отвечает за предоставление /обновление конфигураций для задач, но что именно?Это какой-то кусок кода, который будет работать над кластером Connect?Если да, я полагаю, рабочий инициировал это, но делает ли это произвольным на одной рабочей JVM?Кроме того, существует только один экземпляр соединителя или одновременно запущено несколько экземпляров?
Вопросы такого же типа для задач, когда мы отправляем соединитель в кластер Connect (рабочие), какдостигают ли они консенсуса: «Хорошо, мы выполним эту задачу у этого работника, а эту задачу у этого другого работника»?Как они узнают о том, сколько задач на самом деле выполняется или нет?