Kafka 是一个分布式流平台,常用于消息队列和实时数据处理。

一、安装准备

Kafka 依赖 Java 环境和 ZooKeeper,请提前安装:

  • JDK 8+
  • ZooKeeper(Kafka 2.8 后可选)

二、启动步骤

  1. 启动 ZooKeeper:
bash复制编辑bin/zookeeper-server-start.sh config/zookeeper.properties
  1. 启动 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

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注