Kafka quick start (Mac指令)

Posted 2022-12-06 一只猪的思考

1.安装软件

官网链接
点击上述链接

选择上述推荐版本下载

选择推荐链接下载即可

2.修改配置文件

找到zookeeper.properties和server.properties



分别改成本机存放日志信息的目录即可

3.简单实用

官方笔记点击下述链接
官方网址

下面是我的使用操作

• 存放路径（看自己情况）

cd /Volumes/software/kafka_2.13-3.1.0

• mac运行路径（看自己的情况）

/Volumes/software/kafka_2.13-3.1.0/bin

• 启动服务器 （先启动zookeeper服务器，再启动kafka） ！！！千万不要手动暴力关闭，用下面的命令关闭

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

• 创建主题

kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1  --topic test

• 查看当前服务器的主题

	
kafka-topics.sh --list --bootstrap-server localhost:9092

• 创建生产者，往指定主题上发消息

kafka-console-producer.sh --broker-list localhost:9092 --topic test

• 消费者

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

• 关闭zookeeper服务器

zookeeper-server-stop.sh

• 关闭kafka服务器

kafka-server-stop.sh

后台启动方法

[root@VM-16-10-centos kafka_2.13-3.1.0]# bin/zookeeper-server-start.sh -daemon config/zookeeper.properties 

[root@VM-16-10-centos kafka_2.13-3.1.0]# nohup bin/kafka-server-start.sh config/server.properties 1>/dev/null 2>&1 &