中间件系列 - Kafka3.x从入门到精通

Kafka是一种高吞吐量、可持久化、分布式消息系统，它是Apache软件基金会开发的一个开源项目。Kafka3.x版本在原有基础上进行了一系列的改进和优化，以下是一些常用的Kafka命令和配置示例。

1. 启动Zookeeper服务

bin/zookeeper-server-start.sh config/zookeeper.properties

2. 启动Kafka服务

bin/kafka-server-start.sh config/server.properties

3. 创建一个Topic

bin/kafka-topics.sh --create --topic test --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092

4. 查看所有Topic

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

5. 生产消息

bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092

6. 消费消息

bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092

7. 配置文件示例（server.properties）

broker.id=0
listeners=PLAINTEXT://:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181

以上命令和配置示例涵盖了Kafka的基本操作和配置，能帮助开发者快速理解和上手Kafka。