下载地址:http://archive.apache.org/dist/kafka/0.10.0.0/kafka_2.11-0.10.0.0.tgz
修改配置文件/usr/kafka_2.11-0.10.0.0/config/server.properties
log.dirs=/usr/kafka_2.11-0.10.0.0/logs #创建此目录
修改配置文件/usr/kafka_2.11-0.10.0.0/config/zookeeper.properties
dataDir=/usr/zookeeper #zookeeper安装地址
后台启动zookeeper: nohup bin/zookeeper-server-start.sh config/zookeeper.properties 2>&1 &
后台启动kafka: nohup bin/kafka-server-start.sh config/server.properties 2>&1 &
创建topic:
bin/kafka-topics.sh --create --zookeeper ip:2181 --replication-factor 2 -- partitions 3 --topic test
查看topic:
bin/kafka-topics.sh --list --zookeeper ip:2181
生产数据:
bin/kafka-console-producer.sh --broker-list ip:9092 --topic test
消费者消费数据:
bin/kafka-console-consumer.sh --from-beginning --topic test --zookeeper ip:2181
原文:https://www.cnblogs.com/chong-zuo3322/p/12056643.html