sqlite - kafka jdbc源连接器: time stamp mode is not working for sqlite3

Question

我尝试建立一个数据库，其中包含带有时间戳列的表。我正在尝试实现时间戳模式来捕获数据库中的增量更改。

但是 kafka-connect-jdbc 没有从表中读取任何数据。这是我所做的。

创建了一个表。

sqlite> CREATE TABLE test_timestamp(id integer primary key not null,
   ...>                   payment_type text not null,
   ...>                   Timestamp DATETIME DEFAULT CURRENT_TIMESTAMP,
   ...>                   user_id int not null);
sqlite> INSERT INTO test_timestamp (ID, PAYMENT_TYPE, USER_ID) VALUES (3,'FOO',1);
sqlite> select * from test_timestamp;
3|FOO|2019-06-18 05:31:22|1

我的 jdbc-source 连接器配置如下:

$ curl -s "http://localhost:8083/connectors/jdbc-source/config"|jq '.'
{
  "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
  "mode": "timestamp",
  "timestamp.column.name": "timestamp",
  "topic.prefix": "testdb-",
  "validate.non.null": "false",
  "tasks.max": "1",
  "name": "jdbc-source",
  "connection.url": "jdbc:sqlite:/tmp/test.db"
}

jdbc-source-connector 成功加载并创建主题

$ kafka-topics --list --bootstrap-server localhost:9092
..
testdb-test_timestamp

但是主题中没有出现任何数据。

有什么帮助吗？

提前致谢。

Answer 1

偶然发现类似的问题。就我而言，连主题都没有创建。发现连接工作人员的时区必须与数据库的时区相同。根据此 list 正确设置连接工作线程的属性文件中的 db.timezone 属性(在 SHORT_IDS 部分下)使其正常工作:

db.timezone=Asia/Kolkata