Flume从一个java程序接受随机生成的数据,并传至kafka,java程序通过http协议连接flume
把flume安装目录下的配置文件复制一份到任意路径如:/home/hadoop/flume.conf
进入文件修改: vi /home/hadoop/flume.conf
# Define a memory channel called ch1 on agent1
agent.channels.cnl.type = memory
agent.channels.cnl.capacity = 1000
agent.channels.cnl.thransaction = 100
agent.channels.cnl