1、解压tgz文件
tar zxvf PROJECT2.tgz -C /root
2、修改两个文件
broker.id
log.dirs
启动zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
启动kafka
bin/kafka-server-start.sh config/server.properties
创建一个topic 并指定参数
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic imooc_ad_test
打印topic的list
bin/kafka-topics.sh --list --zookeeper localhost:2181
开启消息发布方
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic imooc_ad_test
开启消息订阅方
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic imooc_ad_test --from-beginning
查看topic的详细描述
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic imooc_ad_test
