时间戳

首页 > 解决方案 > 如何执行 JDBC Kafka 连接器 jar

jdbc - 如何执行 JDBC Kafka 连接器 jar

问题描述

我克隆了https://github.com/confluentinc/kafka-connect-jdbc，但我在理解如何执行它时遇到了问题。

标签： jdbcapache-kafkaapache-kafka-connect

解决方案

kafka-connect-jdbc是一个 Kafka 连接器，用于将数据加载到任何 JDBC 兼容的数据库中。可以在此处找到此连接器的文档。

JDBC 源连接器的最小示例（来自 sqlite db）

下载Confluent 并使用启动服务confluent start

创建一个 sqlite 数据库

sqlite3 test.db

创建一个表并添加一些行：

CREATE TABLE users(id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, username VARCHAR(255));
INSERT INTO users(username) VALUES('giorgos');

加载 JDBC 源连接器：

confluent load jdbc-source

（您的输出应该类似于:)

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

运行控制台使用者以使用主题中生成的数据test-sqlite-jdbc-users：

./bin/kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic test-sqlite-jdbc-users --from-beginning
{"id":1,"name":{"string":"giorgos"}}

推荐阅读