kafka connect avro控制台

oalqel3c  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(320)

我正在关注@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上也在云中尝试过。同样的问题。任何见解都将不胜感激。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题