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