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