如何用无源码的Kafka频道配置Flume？

Question

如果在配置中没有指定源，它会报错。根据文件:

Kafka 通道可用于多种场景：

>

使用Flume源和汇-它为事件提供了可靠且高度可用的通道

使用Flume源和拦截器，但没有接收器-它允许将Flume事件写入Kafka主题，供其他应用程序使用

使用Flume接收器，但没有源-这是一种低延迟、容错的方式，可以将事件从Kafka发送到Flume接收器，例如HDFS、HBase或Solr

https://flume.apache.org/FlumeUserGuide.html

我对场景3很感兴趣，但是在官方水槽文档中没有这样的例子。

问候

Answer 1

您可以为源提供一些伪名称，如：

agent.sources = dummySource
agent.sinks = hdfsSink
agent.channels = kafkaChnl

并提供hdfsSink和kafkaChnl的配置

Answer 2

在较新版本的 CDH（在我的情况下为 5.14）上的水槽配置中可以省略水槽代理源。仅发出警告。