rocketmq-flink-plugin sink and source
Switch branches/tags
Nothing to show
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.idea
src/main
.gitignore
LICENSE
README.md
pom.xml

README.md

rocketmq-flink-source-plugin

RocketMQSource

该工具为第一个版本作为雏形,本人会陆续修改,目前还在寻找更好的解决方案

快速开始

  • 在Flink中调用即可,参数通过构造器传入.
   /**
    DataStream<String> rockMQStream = sourceStream
                   .map(new NuiFlier());
           rockMQStream.addSink(new RocketMQSource(args...));
   */

未完成(以下会同步完成Source)

  • RocketMQ Sink,Mongodb Sink, Hdfs Sink,CrateDB Sink,Hbase Sink

  • 目前只是一个Demo 希望大家多多支持,详情关注博客.

  • ![https://firsh.me]