1
# 解压到指定目录
2
tar -zxvf kafka_2.13-3.5.1.tgz
3
mv kafka_2.13-3.5.1 /opt/kafka

1
# Linux 配置示例
2
broker.id=1
3
log.dirs=/opt/kafka/logs
4

5
# Windows 配置示例
6
broker.id=1
7
log.dirs=D:/env-java/kafka_2.13-3.5.1/kafka-logs

1
# 启动 ZooKeeper
2
## Linux
3
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
4
## Windows
5
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
6

7
# 启动 Kafka
8
## Linux（后台启动，推荐）
9
cd /opt/kafka
10
nohup bin/kafka-server-start.sh config/server.properties 2>&1 &
11
# 或者
12
bin/kafka-server-start.sh -daemon config/server.properties
13

14
## Windows
15
bin\windows\kafka-server-start.bat config\server.properties

1
# 创建 Topic
2
## Linux
3
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 \
4
  --replication-factor 1 --partitions 1 --topic test
5

6
# 查看 Topic 列表
7
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
8

9
# 查看 Topic 详情
10
bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test
11

12
# 删除 Topic
13
bin/kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic test
14

15
# 启动 Producer（生产者）
16
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
17

18
# 启动 Consumer（消费者，从头消费）
19
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 \
20
  --topic test --from-beginning
21

22
# 删除 Topic 数据（需要 delete_script.json 文件）
23
bin/kafka-delete-records.sh --bootstrap-server localhost:9092 \
24
  --offset-json-file delete_script.json

1
{
2
  "partitions": [
3
    {
4
      "topic": "test",
5
      "partition": 0,
6
      "offset": -1
7
    }
8
  ]
9
}