Flume有多个第三方插件可支持AMQP源。
为什么我们要发送消息到rabbitmq或qpid，然后发送到水槽而不是直接发送到水槽？
我想念什么吗？
另外，在什么情况下我应该使用Qpid，rabbitMQ之类的消息队列，而在Flume之类的场合呢？
我阅读了Qpid，RabbitMQ保证订购的交货对我而言并不重要。
还有其他区别吗？
我们可以添加 channel 并动态地向正在运行的水槽代理下沉吗？使用文件滚动接收器向源添加新通道，不需要更改任何代码，只需更改conf文件并重新启动即可。有没有办法动态地做到这一点，即不重新启动水槽代理
最佳答案
它基本上取决于您的用例。正如您所提到的，在您的用例中，有序交付并不重要，那么Flume可能适合。实际上，由于此功能，Flume速度更快，并且容错设置更便宜。 Check this link了解更多详细信息。
此外，Flume非常适合处理Hadoop环境(HDFS作为接收器)，因为它实际上是从此演变而来的。而且，出于同样的原因，您还会看到用例，它们通过Flume推送RabbitMQ(作为源)消息。
关于hadoop - 为什么Flume需要一个AMQP源？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/18188505/