# br-kafka 消息队列

License Crates.io Version

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

配置

配置文件