1.先启动zookeeper
./zkServer.sh start
2.启动kafka
./kafka-server-start.sh -daemon ../config/server.properties &
3.
./kafka-console-producer.sh --broker-list 192.168.10.130:9092 --topic xdclass-topic
4.
./kafka-console-consumer.sh --bootstrap-server 192.168.10.130:9092 --from-beginning --topic xdclass-topic
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)