1.快速入门
使用kafka提供的脚本工具
- linux上安装java,zookeeper,kafka,启动zookeeper(zkServer.sh staart),再启动kafka(bin/kafka-server-start.sh config/server.properties)
- 创建topic (bin/kafka-topics.sh --create --zookeeeper localhost:2181 --topic demo --partitions 1 --replication-factor 1)
- 创建生产者往主题里发送消息 (bin/kafka-console-producer.sh --broker-list localhost:9092 --topic demo >hello >kafka)
- 创建消费者从主题里读取消息(bin/kafka-console-consumer.sh --broker-list localhost:9092 --topic demo >hello >kafka)
2.消息引擎系统