Источник Kafka Connect Cassandra не получает данные для поля timeuuid - PullRequest
Новая
       103

Источник Kafka Connect Cassandra не получает данные для поля timeuuid

0 голосов
/ 29 ноября 2018

Все, я использую разъем источника линз Кассандра для Кафки 1.0.0.Я сделал все настройки, как упомянуто при быстром запуске.И это тоже работает.Но проблема в том, что мой соединитель не получает данные, как только я предоставлю начальное смещение в моем файле конфигурации.В консоли я получаю 

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 Ответ

0 голосов
/ 23 января 2019

Можете ли вы проверить, совпадает ли часовой пояс, из которого вы используете ваш соединитель, с вашей базой данных.Иногда может случиться, что вы указали правильное время в файле конфигурации, но ваш процесс работает с другим часовым поясом (-Duser.timezone=UTC).

...