欢迎光临
我们一直在努力

FlumeNG+Kafka

现在有一个需求,需要用Flume-NG收集日志到Kafka中,中间经过两个Flume最后到达Kafka的Topic中:

flume_kafkaKafka的安装请参考《Kafka单个Zookeeper三节点的安装步骤

1.环境准备

  • JDK:1.8
  • OS:Centos6.5
  • Flume:1.6.0
  • Kafka:2.11-0.10.0

2.配置FLume

Flume1:

Flume2:

3.Kafka操作

创建Topic:

创建生产者:

然后启动Flume2,启动Flume1,利用RestClient发送一个Https请求的数据,将会在Kafka消费者中看到消息。

未经允许不得转载:李阳博客 » FlumeNG+Kafka

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址