Как установить кафку топика-фактора репликации в 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}