Изменение имени реплицированного топика на целевом кластере#

При репликации Corax Mirror Maker 2 переименовывает исходный топик для обеспечения гарантии, что события (записи, сообщения) из разных кластеров не записываются в один и тот же раздел топик/партицию. Алгоритм переименования по умолчанию определяется в классе DefaultReplicationPolicy.java: {source_topic_name} переименовывается в {source}.{source_topic_name}, пример:

ru-west         ru-east
=========       =================
                bar-topic
foo-topic  -->  ru-west.foo-topic

Возможно изменить разделитель (точку) через параметр replication.policy.separator, например:

ru-west->ru-east.replication.policy.separator = _

Полностью переопределить политику переименования можно переопределив replication.policy.class.