Mac下Kafka安装与启动

2020-08-10  本文已影响0人  jyhnp

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

上一篇 下一篇

猜你喜欢

热点阅读