目录

1、启动


 

1、启动

#启动zookeeper
./kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic t1

/opt/kafka_2.13-3.1.0/bin   ./kafka-console-producer.sh --broker-list ip:9092 --topic topicTest

/opt/kafka_2.13-3.1.0/bin   ./kafka-console-consumer.sh --bootstrap-server ip:9092 --from-beginning --topic topicTest

#启动logstash
../bin/logstash -f ./logstash-kafka-es.conf

点赞(0) 打赏

评论列表 共有 0 条评论

暂无评论

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部