融合控制中心已启动并正在运行,我能够在connect选项卡下配置JDBCsource连接器...。在测试和验证屏幕上,它显示最终的Json,如下所示,我单击启动按钮,但没有任何反应。这是UI问题吗?在设置连接器时是否需要添加更多属性
{
"key.converter.schema.registry.url": "http://kafka1:8081",
"value.converter.schema.registry.url": "http://kafka1:8081",
"name": "Test",
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"key.converter": "io.confluent.connect.avro.AvroConverter",
"value.converter": "io.confluent.connect.avro.AvroConverter",
"connection.url": "jdbc:mysql://ipaddress:3306/connect_kafka",
"connection.user": "user",
"connection.password": "password",
"table.whitelist": [
"confluent_connect"
],
"mode": "timestamp",
"timestamp.column.name": [
"load_ts"
],
"validate.non.null": false,
"topic.prefix": "mysql"
}
我建议您直接使用Connect REST API,而不使用Control Center。
这将使您无需依赖clicky-clicky操作即可验证成功。