#kafka #queue #df #carryxd

df-kafka

This is an kafka queue

2 releases

0.1.3 Feb 17, 2023
0.1.2 Jan 21, 2023
0.1.1 Jan 18, 2023
0.1.0 Jan 15, 2023

#10 in #carryxd


Used in 2 crates (via df-plugin)

MIT license

11KB
189 lines

df-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

配置

配置文件

Dependencies

~1.5–2.1MB
~43K SLoC