Предположим, я развернул рабочий контейнер Kafka Connect с исходным соединением, уже настроенным на tasks.max=1
. Без работающих рабочих я вижу в состоянии topi c, что мой соединитель и его задача НЕ УКАЗАНЫ. Рабочий развернут и работает, и примерно через минуту я вижу, что мой соединитель и его задача РАБОТАЮТ. Затем предположим, что я развернул второй экземпляр того же контейнера и запустил его. Я надеялся, что новый рабочий ускорится, и ему нечего делать, но вместо этого я вижу, что новый рабочий дает мне бесконечные Catching up to assignment's config offset.
предупреждения, старый рабочий не показывает ошибок или предупреждений, а мой соединитель и его задача go находятся в статусе UNASSIGNED. и оставить работу.
Может кто-нибудь помочь мне понять это поведение? Где документировано, что происходит, когда у вас два хоста, на которых работают рабочие с одинаковым идентификатором группы и одинаковым всем?