У меня есть 5 кластеров kafka, и один из них запускает kafkamirror, чтобы использовать из других 4 kakfa и производить для основного кластера kafka.
Я пробовал последнюю версию kafka отдельно, и мои приложения, кажется, отлично работает с новейшей версией. Процесс обновления, как описано в обновлении Kafka https://kafka.apache.org/documentation/#upgrade, является непрерывным обновлением, сначала переходя на 2.5.0 и поддерживая протокол посредника с 0.10.0, а затем повторяющийся перезапуск с более новым протоколом
Проблема в том, что создатель зеркала не имеет времени простоя в процессе обновления, чтобы избежать потери сообщений. Я читал, что сначала нужно обновить потребителей, в этом случае mirrormaker является производителем и потребителем одновременно, поэтому я попытался сначала обновить мой основной кластер kafka, и теперь он работает с 2.5.0 с протоколом 2.5.0, а другой кластер моих тестов все еще на 0.10.0. Когда я пытаюсь запустить зеркало, я получаю некоторые предупреждения / ошибки, потому что я все еще использую старые устаревшие конфигурации:
По какому пути следует перейти для обновления?