我正在使用带 MSK 的 Debezium MySQL,设置非常简单。与 MySQL (Aurora) 的连接测试良好。Kafka主题创建,列表都可以。
但是,当我运行连接器时,经过大量滚动信息后,我得到
WARN [Producer clientId=xxx] Error while fetching metadata with correlation id 1 : {xxx.xxx=INVALID_REP
LICATION_FACTOR} (org.apache.kafka.clients.NetworkClient:1100)
他们中的很多人不断出现,并且连接器无法正常工作。