kafka-connect: kafka-connect-cassandra-1.2.1-2.1.0-all.jar
Мои данные внутри Кассандры помечены временем эпохи, сохраненным как bigint.Я хочу получить эти данные в тему kafka, используя инкрементный режим внутри kafka connect.Согласно спецификации - мне нужно иметь поле Timestamp, Timeuuid, Token, чтобы справиться с этим.
Моя первоначальная идея заключается в том, что в конечном итоге я смогу использовать TimestampConverter$Value внутри рабочей конфигурации, но, в конце концов, я думаю, этоэто не путь.Преобразование времени работает с групповым пулом.В инкрементном режиме я получил:
Codec not found for requested operation: [bigint <-> java.util.Date]
, что может быть логично, так как до того, как вы выполняете преобразование, вам как-то нужно объединить данные.
Вопрос:
Есть ли способ подключить Кафку к Кассандре с инкрементным режимом в такой конфигурации, где единственным полем отметки времени является bigint, состоящий из эпохи, и нет доступного поля Timeuuid || Timestamp?
Спасибо, привет, Крис