br-kafka

Crates.iobr-kafka
lib.rsbr-kafka
version0.2.1
sourcesrc
created_at2023-04-02 09:24:48.656908
updated_at2024-10-24 20:07:45.281191
descriptionThis is an kafka queue
homepage
repository
max_upload_size
id827932
size27,138
携带 (carryxd)

documentation

README

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

配置

配置文件

Commit count: 0

cargo fmt