KafkaJDBCsink连接器无法访问正确的连接器配置

此问题通常是由于连接器配置的名称不正确导致的。在Kafka Connect worker配置文件中，必须确保以下配置项中的“topics”和数据库表名称完全匹配：

• sink连接器的connector.class和connection.url配置项
• sink连接器的topics配置项

例如，如果您的数据库表名为：“test_table”，则以下配置项必须完全匹配：

# Configure the JDBC sink connector
name=my-jdbc-sink
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
tasks.max=1
topics=test_topic
connection.url=jdbc:mysql://localhost:3306/my_db

请注意以上配置项中的“topics”和“connection.url”项的值是否正确。

另外，为了确保Kafka Connect worker能够正确识别配置更改，您应该重启它以使更改生效。

如果问题仍然存在，请确保数据库的连接已正确配置，并查看Kafka Connect worker或sink连接器的日志以获取更多信息。