Есть ли возможность ограничить / ограничить скорость процесса MirrorMaker , чтобы целевой кластер всегда отставал от исходного кластера предсказуемым образом?
Помогает ли эта опция --num.streams регулировать поток?
Мне приходится регулировать и поддерживать задержку на целевом кластере, чтобы пользователи могли легко переключаться на целевой кластер, не пропуская ни одного сообщения для обработки.
Мои потребители могут обрабатывать дубликаты в сообщениях. Но я также не хочу, чтобы они принимали сообщения с самого начала / самого раннего.
Кафка Версия: 0,9