Как установить кафку топика-фактора репликации в maxwell

У меня есть три брокера kafka, и я использовал maxwell, слушая Mysql binlog.

потому что я установил kafka_topic=%{база данных}_%{таблица} в конфигурации Maxwell, поэтому я думаю, создать тему предварительно с kafka-topics.sh как ниже не подходит

bin/kafka-topics.sh --create --zookeeper 192.168.6.56:2181 --replication-factor 3 --partitions 3 --topic {dbName}_{tableName}

0 ответов

Другие вопросы по тегам