kafka-connect: kafka-connect-cassandra-1.2.1-2.1.0-all.jar

我在cassandra里面的数据都有时间戳，时间被保存为bigint。我想在kafka connect中使用增量模式将这些数据检索到kafka主题中。根据规范-我需要有时间戳，timeuuid，令牌字段来处理这个。
我最初的想法是，最终，我可以 TimestampConverter$Value 内部工人配置，但毕竟，我猜这不是办法。时间转换与大容量池一起工作。在增量模式下，我得到：

Codec not found for requested operation: [bigint <-> java.util.Date]

这可能是合乎逻辑的，因为在进行转换之前，您需要以某种方式汇集数据。
问题是：
在这样一种配置中，只有包含epoch的bigint是timeuuid | | timestamp字段，没有可用的timeuuid | | timestamp字段，有没有办法用增量模式将kafka连接到cassandra？
谢谢你，克里斯