debezium报错：Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.ClusterAuthorizationException: Cluster authorization failed.
- “trace”:"org.apache.kafka.connect.errors.ConnectException: Creation of database history topic failed, please create the topic manually
- Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.ClusterAuthorizationException: Cluster authorization failed.
解决方法如下：
- “database.history.kafka.topic”: “debezium-dbhistory-mysql-optics-prod”
- 手动创建database.history.kafka.topic
- sh -x /data/service/kafka/bin/kafka-topics.sh --zookeeper t-shbs-sqe-hadoop-kafka-001:2181 --create --topic debezium-dbhistory-mysql-optics-prod --partitions 3 --replication-factor 3
