Mac下Kafka安装与启动

我的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:从头开始消费
在生产端输入信息后回车,到消费者端可以看到生产端发送的信息

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

友情链接更多精彩内容