br-kafka
| Crates.io | br-kafka |
| lib.rs | br-kafka |
| version | |
| source | src |
| created_at | 2023-04-02 09:24:48.656908+00 |
| updated_at | 2025-05-05 10:48:50.18513+00 |
| description | This is an kafka queue |
| homepage | |
| repository | |
| max_upload_size | |
| id | 827932 |
| Cargo.toml error: | TOML parse error at line 24, column 1 | 24 | autolib = false | ^^^^^^^ unknown field `autolib`, expected one of `name`, `version`, `edition`, `authors`, `description`, `readme`, `license`, `repository`, `homepage`, `documentation`, `build`, `resolver`, `links`, `default-run`, `default_dash_run`, `rust-version`, `rust_dash_version`, `rust_version`, `license-file`, `license_dash_file`, `license_file`, `licenseFile`, `license_capital_file`, `forced-target`, `forced_dash_target`, `autobins`, `autotests`, `autoexamples`, `autobenches`, `publish`, `metadata`, `keywords`, `categories`, `exclude`, `include` |
| size | 0 |
carryxd (carryxd)
documentation
README
br-kafka 消息队列
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