所有,我使用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
}
}
1条答案
按热度按时间332nm8kg1#
是否可以检查运行连接器的时区与数据库的时区是否相同。有时可能发生这样的情况:您在配置文件中提供了正确的时间,但您的进程在不同的时区运行(
-Duser.timezone=UTC
).