美文网首页
Mac下Kafka安装与启动

Mac下Kafka安装与启动

作者: jyhnp | 来源:发表于2020-08-10 15:34 被阅读0次

我的kafka是在/Applications/kafka_2.11-0.10.2.1目录下,下面都在kafka_2.11-0.10.2.1/bin路径下操作的,mac跟linux指令差不多,Mac是通过sh脚本传参执行命令的

启动

1.先启动zookeeper(kafka自带的)

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

2.启动kafka

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

kafka基本指令

创建一个topic

sh kafka-topics.sh --create --zookeeper localhost:2181 --partitions 2 --replication-factor 1 --topic test1
#输出:Created topic "test1".

--partitions:分区数量
--replication-factor:副本数量(要<=broker数量)

查看topic列表

sh kafka-topics.sh --list --zookeeper localhost:2181
# 输入:test1

创建生产者

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

创建消费者

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

--from-beginning:从头开始消费
在生产端输入信息后回车,到消费者端可以看到生产端发送的信息

相关文章

网友评论

      本文标题:Mac下Kafka安装与启动

      本文链接:https://www.haomeiwen.com/subject/ngjjdktx.html