flum下载安装

agent.sources = seqGenSrc
agent.channels = memoryChannel
agent.sinks = loggerSink

# For each one of the sources, the type is defined
agent.sources.seqGenSrc.type = exec
agent.sources.seqGenSrc.command=tail -f /data/www/logs/apps/userinfo/info.log
# The channel can be defined as follows.
agent.sources.seqGenSrc.channels = memoryChannel

# Each sink‘s type must be defined
agent.sinks.loggerSink.type = org.apache.flume.sink.kafka.KafkaSink
agent.sinks.loggerSink.topic = userinfoTopic
agent.sinks.loggerSink.brokerList = 10.10.12.173:9092
agent.sinks.loggerSink.batchSize = 20
agent.sinks.loggerSink.requiredAcks = 1
#Specify the channel the sink should use
agent.sinks.loggerSink.channel = memoryChannel

# Each channel‘s type is defined.
agent.channels.memoryChannel.type = memory

# Other config values specific to each type of channel(sink or source)
# can be defined as well
# In this case, it specifies the capacity of the memory channel
agent.channels.memoryChannel.capacity = 100