Kafka Connect Avro Console Потребительская подвеска - PullRequest
Новая
       32

Kafka Connect Avro Console Потребительская подвеска

0 голосов
/ 30 июня 2018

Я следую учебнику @RobinMoffat "Simplest Useful .." для 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. Точно такая же проблема. Любое понимание будет с благодарностью.

...