【发布时间】:2019-12-26 20:59:36
【问题描述】:
我正在运行 Confluent Kafka docker cp-all-in-one。 我想将一些主题数据插入 MS SQL 服务器。我创建新的数据库和表。使用 Confluent Control Center 我添加了 JdbcSinkConnector。
连接器配置:
"name": "jdbc2users",
"connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
"errors.log.enable": "true",
"errors.log.include.messages": "true",
"topics": [
"users"
],
"errors.deadletterqueue.context.headers.enable": "true",
"connection.url": "jdbc:sqlserver://192.168.1.55:1433;databaseName=ktest;",
"connection.user": "kuser",
"connection.password": "*****",
"insert.mode": "INSERT",
"auto.create": "true",
"auto.evolve": "true",
"max.retries": "10"
连接器正在启动,但在几秒钟内将状态更改为降级。我已经尝试更改连接 URL,但总是失败。 在哪里可以找到此连接器日志文件? 提前谢谢!
【问题讨论】:
-
错误应该在 Kafka Connect 的日志中可见。
-
docker logs <image_name>? -
其中“connect”是 cp-all-in-one.yml 文件中服务的名称。 $ docker-compose 日志连接
标签: docker apache-kafka apache-kafka-connect