# br-kafka 消息队列
----

[![License](https://img.shields.io/crates/l/MIT)](LICENSE-MIT)
[![Crates.io Version](https://img.shields.io/crates/v/br-kafka)](https://crates.io/crates/br-kafka)

## Mac 操作

### 启动

```shell
brew services start kafka
```

### 重启

```shell
brew services restart kafka
```

### 停止

```shell
brew services stop kafka
```

### 启动状态

```shell
brew services list
```

## linux 操作

### 依赖

```shell
sudo apt-get install openjdk-8-jdk
```

### 安装

```shell
wget "https://dlcdn.apache.org/kafka/3.3.1/kafka_2.13-3.3.1.tgz"
tar -xzf "kafka_2.13-3.3.1.tgz"
cd "kafka_2.13-3.3.1"
```

### 启动

```shell
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
bin/kafka-server-start.sh -daemon config/server.properties
```

### 测试启动

```shell
bin/zookeeper-server-start.sh  config/zookeeper.properties
bin/kafka-server-start.sh  config/server.properties
```

## 消息主题创建

````shell
bin/kafka-topics.sh -create --bootstrap-server 0.0.0.0:9092 --replication-factor 1 --partitions 1 --topic tests
````

## kafka停止

````shell
bin/kafka-server-stop.sh
bin/zookeeper-server-stop.sh
````

## 删除主题

````shell
bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic xxx
````

### 配置

[配置文件](server.properties)