kafka

"我要学死消息队列"

Posted by hzy on May 7, 2026

初识 Kafka

  • zookeeper启动方式
  • KRaft启动

安装Kafka

1
2
3
4
5
docker pull apache/kafka:3.7.0
docker run -p 9092:9092 apache/kafka:3.7.0
docker exec -it kafka sh
cd /opt/kafka/bin
./kafka-topic.sh

使用Kafka

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
./kafka-topic.sh --create --topic hello --bootstrap-server localhost:9092

./kafka-topic.sh --list --bootstrap-server localhost:9092

./kafka-topic.sh --delete --topic hello --bootstrap-server localhost:9092

./kafka-topic.sh --describe --topic hello --bootstrap-server localhost:9092

# alter 只能改参数,topic 名字改不了
./kafka-topic.sh --alter --topic hello --partition 5 --bootstrap-server localhost:9092


./kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

./kafka-console-consumer.sh --topic quickstart-events --from-begining --bootstrap-server localhost:9092


/etc/kafka/docker# docker cp f49748080656:/etc/kafka/docker/server.properties ./

    # 配置
    listeners:  0.0.0.0
    advertised.listeners = PLAINTEXT://ip:9092

docker run --volume /etc/kafka/docker:/mnt/shared/config -p 9092:9092 apache/kafka