kafka入门学习使用

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/Curryth_/article/details/89471754

安装(mac版)

1. 安装命令: brew install kafka

在这里插入图片描述
出现: zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties & kafka-server-start /usr/local/etc/kafka/server.properties
表示:安装成功

2. 首先要启动zookeeper(博主之前只启动了kafka,在创建topic时就报错了)
brew services start  zookeeper
3. 启动kafka
brew services start kafka

启动成功后。。。。

创建topic:test(可自己命名)
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
结果:Created topic test.

然后

查看自己的topic-list
kafka-topics --list --zookeeper localhost:2181
结果:test

进行消费者与生产者测试

进入到bin目录
cd /usr/local/Cellar/kafka/2.2.0/libexec/bin/

创建生产者

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

在这里插入图片描述
创建消费者

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

在这里插入图片描述

猜你喜欢

转载自blog.csdn.net/Curryth_/article/details/89471754