Flume学习-采集端口数据存入kafka_socket flume kafka

作者：Guff_9hys | 2024-07-29 09:52:57

踩

socket flume kafka

启动zookeeper、kafka并创建kafka主题

./bin/zkServer.sh start


./bin/kafka-server-start.sh -daemon ./config/server.properties
 
./bin/kafka-topic.sh --create --topic hunter --partitions 3 --replication-factor 1 --zookeeper localhost:9092

2、创建flume-kafka.conf配置文件

用于采集socket数据后存入kafka

在flume文件夹中的conf下新建flume-kafka.conf配置文件

vim flume-kafka.conf


a1.sources = s1
a1.channels = c1
a1.sinks = k1
 
a1.sources.s1.type = netcat
a1.sources.s1.bind = localhost 
a1.sources.s1.port = 10050 
 
a

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Guff_9hys/article/detail/898235

Flume学习-采集端口数据存入kafka_socket flume kafka

启动zookeeper、kafka并创建kafka主题

2、创建flume-kafka.conf配置文件

在flume文件夹中的conf下新建flume-kafka.conf配置文件