?1.进入kafka文件夹
2.1启动zookeeper服务?
? ?kafka_2.12-1.0.0 bin/zookeeper-server-start.sh config/zookeeper.properties
?
3启动kafka服务?
? ?kafka_2.12-1.0.0 bin/kafka-server-start.sh config/server.properties ?
4创建topic
? ?kafka_2.12-1.0.0 bin/kafka-server-start.sh config/server.properties ??
5向topic中发送消息?
? ?kafka_2.12-1.0.0 bin/kafka-console-producer.sh --broker-list 172.16.37.161:9092 --topic firstTopic
6从topic中消费消息?
? ?kafka_2.12-1.0.0 bin/kafka-console-producer.sh --broker-list 172.16.37.161:9092 --topic firstTopic
?