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

配置

配置文件