【问题标题】:I need a Cassandra Flume Sink我需要一个 Cassandra Flume 水槽
【发布时间】:2015-03-07 23:10:22
【问题描述】:

我正在尝试查找 Cassandra 水槽水槽的模板/样本。我在网上查了一下,我在github上找到的两个项目都有过时的依赖项(JAR),我在任何地方都找不到那些神器:(。

谢谢!期待任何参考。

【问题讨论】:

    标签: cassandra flume flume-ng nosql


    【解决方案1】:

    你看过stratio-ingestion 吗?

    Stratio-ingestion 是一个 Flume 发行版,带有一些额外的 source/sinks/morphlines 并修复了一些官方错误。

    它还有一个Cassandra Sink,您可以轻松地插入具有不同配置的水槽事件。

    【讨论】:

    • 谢谢,我目前正在使用 Stratio-Ingestion。它真的很棒!仍然无法让它工作,我有这个错误
    • Caused by: java.lang.ClassNotFoundException: org.kitesdk.morphline.api.Command 我没有使用hadoop,但我使用maven设置了flume。我想我必须添加一些依赖项......
    • 您是否下载了该版本或只是将 Cassandra Sink 添加到您的发行版中?这很奇怪,因为 Sink 不需要该类。也许您必须导入 kite-morphlines-core 来解决错误。给我更多关于如何使用水槽的信息。
    【解决方案2】:

    您可以制作自定义接收器,编辑此cassandra custom sink for flume cassandra 自定义接收器项目以适合您的应用程序,然后清理并构建该项目,在水槽库中添加项目 jar 并进行水槽配置。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2013-11-15
      • 2013-08-13
      • 2021-03-10
      相关资源
      最近更新 更多