Flume 读取RabbitMq消息队列消息，并将消息写入kafka

首先是关于flume的基础介绍 组件名称     功能介绍 Agent代理 使用JVM 运行Flume。每台机器运行一个agent，但是可以在一个agent中包含多个sources和sinks。 Client客户端 生产数据，运行在一个独立的线程。 Source源 从Client收集数据，传递给Channel。 Sink接收器 从Channel收集数据，进行相关操作，运行在一个独立线程。 Chan

>>阅读原文<<