Question

将 Log4j 事件追加到 flume agent 的 avro 源列表中。使用此 appender 的客户端必须在类路径中包含 flume-ng-sdk（例如，flume-ng-sdk-1.9.0.jar）。该 appender 支持循环和随机方案，用于执行负载均衡 。它还支持可配置的退避超时，以便从主机集临时删除向下代理所需属性在 bold 中。

属性名称	默认	说明
Hosts	-	一个以空格分隔的主机：端口列表，Flume（通过 AvroSource）正在侦听事件
选择器	ROUND_ROBIN	选择机制。必须是 ROUND_ROBIN，RANDOM 或自定义 FQDN 到继承自 LoadBalancingSelector 的类。
MaxBackoff	-	一个 long 值，表示负载均衡 客户端将从无法使用事件的节点退回的最长时间（以毫秒为单位）。默认为无退避
UnsafeMode	false	如果为 true，则 appender 在发送事件失败时不会抛出异常。
AvroReflectionEnabled	false	使用 Avro Reflection 序列化 Log4j 事件。
AvroSchemaUrl	-	可从中检索 Avro 架构的 URL。

使用默认值配置的示例 log4j.properties 文件：

#...
log4j.appender.out2 = org.apache.flume.clients.log4jappender.LoadBalancingLog4jAppender
log4j.appender.out2.Hosts = localhost:25430 localhost:25431

# configure a class's logger to output to the flume appender
log4j.logger.org.example.MyClass = DEBUG,flume
#...

使用 RANDOM 负载均衡 配置的示例 log4j.properties 文件：

#...
log4j.appender.out2 = org.apache.flume.clients.log4jappender.LoadBalancingLog4jAppender
log4j.appender.out2.Hosts = localhost:25430 localhost:25431
log4j.appender.out2.Selector = RANDOM

# configure a class's logger to output to the flume appender
log4j.logger.org.example.MyClass = DEBUG,flume
#...

使用退避配置的示例 log4j.properties 文件：

#...
log4j.appender.out2 = org.apache.flume.clients.log4jappender.LoadBalancingLog4jAppender
log4j.appender.out2.Hosts = localhost:25430 localhost:25431 localhost:25432
log4j.appender.out2.Selector = ROUND_ROBIN
log4j.appender.out2.MaxBackoff = 30000

# configure a class's logger to output to the flume appender
log4j.logger.org.example.MyClass = DEBUG,flume
#...