我们正在进行一个项目，其中要求将oracle数据存储在cassandra。为了将数据存储在cassandra中，我们建议首先将oracle中的数据存储到apachekafkamq服务器上，然后使用spark进行操作并保存到cassandra中。对于从oracle到ApacheKafka的实时数据复制，由于高昂的许可成本，我们正在寻找开源的ContinuentTungsten。
有人知道我们能不能直接把钨的增量数据传输给Kafka吗？