1、上传部署包:kafka_2.11-0.11.0.0.tgz 放到/opt/software/
2、解压:tar -zxvf kafka_2.11-0.11.0.0.tgz -C /opt/module/
3、切换目录: /opt/module/kafka_2.11-0.11.0.0/conf
4、修改配置:vim server.properties 修改log.dirs=/opt/module/kafka_2.11-0.11.0.0/data/kafka-logs advertised.listeners=PLAINTEXT://...:9092
5、创建data目录,mkdir data
6、bin/启动:./kafka-server-start.sh …/config/server.properties
7、bin/创建topic:./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --partitions 1 --replication-factor 1 --topic test
8、启动生产模式: ./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
9、启动消费模式:./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test
10、生产窗口发送消息,消费窗口消费消息

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐