我是水槽的新手。目前我正在负载测试我的升级。我使用 HTTP 作为源和文件系统作为接收器的类型。现在我的要求是设置一个多代理流程(2 个代理)。在这种情况下,我需要使用 HTTP 有效负载注入第一个水槽的源,并将数据从接收器发送到另一个类似的水槽的源,并最终将其写入文件。
我应该在第一个代理的 conf 文件中指定什么类型的接收器?
我是水槽的新手。目前我正在负载测试我的升级。我使用 HTTP 作为源和文件系统作为接收器的类型。现在我的要求是设置一个多代理流程(2 个代理)。在这种情况下,我需要使用 HTTP 有效负载注入第一个水槽的源,并将数据从接收器发送到另一个类似的水槽的源,并最终将其写入文件。
我应该在第一个代理的 conf 文件中指定什么类型的接收器?
Flume Avro sink和Avro source专为此类设置而设计。第一个代理使用配置为向第二个代理的 Avro 源发送数据的 Avro 接收器(重要的配置参数是hostname
和port
)。