Кафка + описание лидеров и репликации одного из лидеров не существует

У Mongorestore есть эта возможность добавления поверх того, что уже есть в базе данных, поэтому это поведение можно было бы использовать для объединения двух коллекций:

1. mongodump collection1
2. collection2 .rename (collection1)
3. mongorestore

Еще не пробовал, но может работать быстрее, чем подход map / reduce.