【发布时间】:2017-08-07 17:31:40
【问题描述】:
类似于 jdbc、弹性搜索、hdfs,我需要用于 Kafka 连接的 Java 中 Cassandra 的连接器,但我无法在 Java 中找到任何用于 Cassandra 的连接器。我不知道如何使用 Kafka 与 Cassandra 连接,我尝试过其他方式,例如在消费者组中编写 Cassandra 原始查询,但我认为这不是一种方法。
【问题讨论】:
-
Datamountaineer Stream Reactors 有一个包含所有依赖项的 Cassandra JAR
标签: java cassandra apache-kafka apache-kafka-connect