1.下载
wget http://mirror.bit.edu.cn/apache/kafka/2.1.1/kafka_2.12-2.1.1.tgz
2.解压
tar -zxvf kafka_2.12-2.1.1.tgz
3.cd bin目录运行zookeeper【-daemon表示后台运行】
./zookeeper-server-start.sh -daemon ../config/zookeeper.properties
- 运行kafaka
先修改配置文件 vi config/server.properties
listeners=PLAINTEXT://你的ip:9092
./kafka-server-start.sh -daemon ../config/server.properties
5.创建主题 xunwu_topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic xunwu_topic
网友评论