apache-kafka - 使用用于 sqlite 的 jdbc 连接器使用 kafka 连接构建管道

Question

我是 kafka connect 的新手，试图建立一个管道来获取从 sqlite 到 kafka 主题的数据。

标签： apache-kafkaconfluent-platform

Answer 1

假设您的 sqlite DB 在/tmp/test.db然后使用此配置：

{
  "name": "jdbc-source",
  "config": {
    "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
    "tasks.max": "1",
    "connection.url": "jdbc:sqlite:/tmp/test.db",
    "mode": "incrementing",
    "incrementing.column.name": "id",
    "topic.prefix": "test-sqlite-jdbc-",
    "name": "jdbc-source"
  }
}

有关更多详细信息，请参阅：

• https://docs.confluent.io/current/connect/connect-jdbc/docs/source_connector.html#quick-start
• https://www.confluent.io/blog/simplest-useful-kafka-connect-data-pipeline-world-thereabouts-part-1/