前往小程序,Get更优阅读体验!
立即前往
发布
社区首页 >专栏 >mac环境下使用brew安装Kafka(详细过程)

mac环境下使用brew安装Kafka(详细过程)

原创
作者头像
码农架构
修改2021-01-27 18:11:06
修改2021-01-27 18:11:06
11.4K00
代码可运行
举报
文章被收录于专栏:码农架构码农架构
运行总次数:0
代码可运行

Kafka 实战案例

Kafka 核心原理解

安装kafka

代码语言:javascript
代码运行次数:0
复制
brew install kafka
  • kafka使用zookeeper管理,安装过程会自动安装zookeeper
  • 安装目录:/usr/local/Cellar/kafka/* (*为具体安装的版本)
  • 配置文件目录:/usr/local/etc/kafka

注意:

Homebrew 源没有修改的可以先跳过

control + c

修改kafka启动配置文件

代码语言:javascript
代码运行次数:0
复制
vi /usr/local/etc/kafka/server.properties
  • 该配置为单机版,集群配置请查看博客后续文章
  • 修改kafka的监听地址和端口为localhost:9092
代码语言:javascript
代码运行次数:0
复制
listeners=PLAINTEXT://localhost:9092

依次启动服务

代码语言:javascript
代码运行次数:0
复制
brew services start zookeeper
代码语言:javascript
代码运行次数:0
复制
brew services start kafka
  • 由于kafka依赖zookeeper管理,所以zookeeper需要先启动

创建topic

使用单个分区和只有一个副本的方式来创建一个名为“test”的topic

代码语言:javascript
代码运行次数:0
复制
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看创建的topic

代码语言:javascript
代码运行次数:0
复制
kafka-topics --list --zookeeper localhost:2181

生产消息

通过控制台向“test”topic添加消息

代码语言:javascript
代码运行次数:0
复制
kafka-console-producer --broker-list localhost:9092 --topic test

消费消息

通过控制台消费“test”topic中的消息

代码语言:javascript
代码运行次数:0
复制
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 安装kafka
  • 修改kafka启动配置文件
  • 依次启动服务
  • 创建topic
  • 查看创建的topic
  • 生产消息
  • 消费消息
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档