首页 文章

Kafka JDBC源连接器

提问于
浏览 次
-1

我正在尝试使用JDBC源连接器从SQL Server获取数据 .

我收到错误说

ERROR无法为etc / kafka-connect-jdbc / source-quickstart-sqlserver.properties创建作业

我的属性文件如下所示 . 我错过了什么？

name=test-sqlserver-jdbc-autoincrement
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:sqlserver://******:1433;databaseName=****;user=****l;password=****
table.whitelist=****
mode=incrementing
incrementing.column.name=id
topic.prefix=test-sqlserver-jdbc-

此外，如果我尝试使用 curl http://localhost:8083 /JdbcSourceConnector/config/validate 获取错误详细信息，我会收到错误网址格式错误，我认为这是kafka 10.2.0中的错误

jdbc apache-kafka

2 回答

  • 0

    如果您在实验环境中尝试以下方法 .

    connection.url=jdbc:mysql://127.0.0.1:3306/my_db
connection.user=user
connection.password=pass
useSSL=false

    还要确保递增列名称正确并且它是 auto-increment .

    回复于
  • 1

    尝试使用以下属性文件 .

    name=test-mysql-jdbc-autoincrement
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:mysql://localhost:3306/training?user=admin&password=password@538&useSSL=false

query=select emp.emp_dept_id, emp.timestamp, emp.emp_name, dept.dept_name from kafka_employee emp join kafka_department dept on emp.emp_dept_id = dept.dept_id
mode=timestamp+incrementing

incrementing.column.name=emp_dept_id
timestamp.column.name=timestamp

topic.prefix=test-mysql-jdbc-kp
poll.interval.ms = 1000
    回复于

相关问题