我正在关注@robinmoffat的kafka connect的“最简单有用..”教程,并尝试连接到我自己的mysql数据库。我加载配置文件,然后检查状态:
{
"name": "mysql-9202_Voltage",
"config": {
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "10",
"connection.url": "jdbc:mysql://AWS_mysql_conection_string:3306?user=user&password=pw",
"table.whitelist": "`9202-WiFi_Voltage`",
"mode": "timestamp",
"timestamp.column.name": "TmStamp",
"topic.prefix": "FT-9202V",
"name": "mysql-9202_Voltage"
},
"tasks": [],
"type": null
}
I then check the status and get:
{
"name": "mysql-9202_Voltage",
"connector": {
"state": "RUNNING",
"worker_id": "192.168.1.209:8083"
},
"tasks": [],
"type": "source"
}
然后我跑:
./bin/kafka-avro-console-consumer \
> --bootstrap-server localhost:9092 \
> --property schema.registry.url=http://localhost:8081 \
> --property print.key=true \
> --from-beginning \
> --topic FT-9202V
它就挂在那里。我在mac上本地尝试过这个,在linux上也在云中尝试过。同样的问题。任何见解都将不胜感激。
暂无答案!
目前还没有任何答案,快来回答吧!