Создание потоков репликации#

Поток репликации задается шаблоном вида {кластер-исходник}->{целевой кластер} и определяется набором параметров:

• направление репликации (от какого псевдонима к какому);

• статус репликации (включена/выключена);

• регулярное выражение выбора топиков для репликации. По умолчанию реплицируются все топики и consumer groups;

Примеры шаблонов:

• Active/Active кластер высокой доступности: A->B, B->A.

• Active/Passive(StandBy) кластер высокой доступности: A->B.

• Объединение (например, нескольких кластеров в один): A->K, B->K, C->K.

• Разветвление/распределение (например, из одного кластера в несколько): K->A, K->B, K->C.

• Пересылка: A->B, B->C, C->D.

Примеры настройки:

# Задание псевдонимов кластеров
clusters = source, destination

# Указание брокеров для каждого кластера
source.bootstrap.servers = broker1:9092,broker2:9092
destination.bootstrap.servers = broker3:9092,broker4:9092

# Создание и настройка потока репликации
## Включение и определение направления репликации
source->destination.enabled = true

## Регулярное выражения для выбора топиков
source->destination.topics = my-topic-regex