kafka搭建
来源:原创
时间:2019-09-02
作者:脚本小站
分类:Linux
单机版
安装java环境:
yum install java -y
下载kafka包:
http://kafka.apache.org/downloads
启动zookeeper:kafka中自带的zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
启动kafka:
bin/kafka-server-start.sh config/server.properties
创建topic:
bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test1 --partitions 3 --replication-factor 1
查看topic:
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test1
打开消费者:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1 --from-beginning
打开生产者:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1
然后输入内容在消费者那边看是否有内容输出,如果有则正常。