Kafka 常用操作

### 安装
https://kafka.apache.org/downloads

```
cd /opt
wget https://downloads.apache.org/kafka/3.4.0/kafka_2.13-3.4.0.tgz
tar -xvzf kafka_2.13-3.4.0.tgz kafka_2.13-3.4.0
cd kafka_2.13-3.4.0

apt install openjdk-17-jdk-headless
```

> kafka3.0 之后版本弃用了SimpleAclAuthorizer验证，改为kafka.security.authorizer.AclAuthorizer

### 常用操作

``` bash
root@dt:/# cd /opt/kafka_2.12-2.8.0
root@dt:/# bin/kafka-server-stop.sh
root@dt:/# bin/zookeeper-server-stop.sh
root@dt:/# jps
root@dt:/# bin/zookeeper-server-start.sh -daemon config/zookeeper.properties  -- 后台启动ZooKeeper
root@dt:/# bin/kafka-server-start.sh -daemon config/server.properties  -- 后台启动 Kafka Broker
root@dt:/# jps
```

### 查看进程
```bash
root@ubuntu:/opt/kafka_2.12-2.8.0# jps
2928568 Jps
2928459 Kafka
2928083 QuorumPeerMain
```

### 创建主题
```sh
bin/kafka-topics.sh --create --topic first --bootstrap-server localhost:9092
```

### 查看主题列表
```sh
bin/kafka-topics.sh --list --zookeeper localhost:2181
```

### 测试生产者生产消息
```
bin/kafka-console-producer.sh --topic first --broker-list localhost:9092
```

### 测试消费者接收消息
```
bin/kafka-console-consumer.sh --topic first --bootstrap-server localhost:9092 --from-beginning
```