Kafka 是一个分布式流平台,常用于消息队列和实时数据处理。
一、安装准备
Kafka 依赖 Java 环境和 ZooKeeper,请提前安装:
- JDK 8+
- ZooKeeper(Kafka 2.8 后可选)
二、启动步骤
- 启动 ZooKeeper:
bash复制编辑bin/zookeeper-server-start.sh config/zookeeper.properties
- 启动 Kafka:
bash复制编辑bin/kafka-server-start.sh config/server.properties
三、创建 Topic 并测试
创建一个 topic:
bash复制编辑bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092
发送和消费消息:
bash复制编辑# 发送
bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
# 消费
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092