基于flume-ng v1.6.0 自定义的对接RocketMQ的Source和Sink，用于数据的输入和输出。可自定义参数
Primary LanguageJava
No issues in this repository yet.