欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

mac系统安装kafka

程序员文章站 2022-06-14 08:18:01
...

本文采用homebrew安装kafka,如果还未安装homebrew,请参考我的上篇博客homebrew安装

  1. 安装zookeeper
brew install zookeeper

默认安装位置

启动文件: /usr/local/Cellar/zookeeper/3.5.8/bin/
配置文件: /usr/local/etc/zookeeper/

  1. 启动zookeeper 服务
zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &
  1. 安装kafka
brew install kafka
  1. 修改Kafka服务配置文件
修改配置文件 /usr/local/etc/kafka/server.properties

解除注释: listeners=PLAINTEXT://localhost:9092
  1. 启动Kafka服务
kafka-server-start /usr/local/etc/kafka/server.properties &
  1. 新建topic
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看已有主题list
kafka-topics --list --zookeeper localhost:2181

修改分区数
kafka-topics --zookeeper localhost:2181 --alter --topic test  --partitions 2
  1. 创建生产者
kafka-console-producer --topic test --broker-list localhost:9092
  1. 创建消费者
kafka-console-consumer --bootstrap-server localhost:9092 -topic test

这时生产者写入一条消息,消费者那里可以收到。

相关标签: kafka zookeeper