#kafka #queue #br #carryxd

br-kafka

This is an kafka queue

5 unstable releases

0.2.1 Oct 24, 2024
0.2.0 Oct 24, 2024
0.1.0 Oct 3, 2024
0.0.2 May 22, 2023
0.0.1 Apr 2, 2023

#359 in HTTP server

48 downloads per month
Used in 2 crates

MIT license

11KB
185 lines

br-kafka 消息队列


License Crates.io Version

Mac 操作

启动

brew services start kafka

重启

brew services restart kafka

停止

brew services stop kafka

启动状态

brew services list

linux 操作

依赖

sudo apt-get install openjdk-8-jdk

安装

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"

启动

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

测试启动

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

消息主题创建

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

kafka停止

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

删除主题

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

配置

配置文件

Dependencies

~1.4–2MB
~40K SLoC