kafka connect cassandra source未获取timeuuid字段的数据

ccrfmcuu  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(319)

所有,我使用Kafka1.0.0镜头Cassandra源连接器。我已经完成了快速入门中提到的所有设置。它也在运行。但问题是,一旦我在配置文件中提供初始偏移量,我的连接器就无法获取数据。在我的控制台上

INFO message for query : "SELECT account_sid,datetime,price,request,response FROM testdb.testtable WHERE datetime > maxTimeuuid(?) AND datetime <= minTimeuuid(?) ALLOW FILTERING executing with bindings (2018-01-01T08:00:00Z, 2018-01-01T11:07:54Z)"

在casandra表上分别执行这个查询时,我得到的是结果。请说明哪里出了问题。提前谢谢你的帮助。
下面是配置文件:

{  
  "name":"cassandra-source",
  "config":{  
    "tasks.max":"1",
    "connector.class":"com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector",
    "connect.cassandra.contact.points":"abc.test.com",
    "connect.cassandra.port":9042,
    "connect.cassandra.username":"user",
    "connect.cassandra.password":"password",
    "connect.cassandra.key.space":"testdb",
    "connect.cassandra.initial.offset":"2018-01-01 00:00:00.0000000Z",
    "connect.cassandra.kcql":"INSERT INTO testtable SELECT account_sid,datetime,price,request,response FROM carrier_lookup_list PK datetime INCREMENTALMODE=TIMEUUID",
    "connect.progress.enabled":true
  }
}
332nm8kg

332nm8kg1#

是否可以检查运行连接器的时区与数据库的时区是否相同。有时可能发生这样的情况:您在配置文件中提供了正确的时间,但您的进程在不同的时区运行( -Duser.timezone=UTC ).

相关问题