Mac系统上通过安装kafka

分类: AUTOMATION 发布于:

安装笔记

使用homebrew 安装kafka

旧版本kafa存在localhost默认无法识别的问题，已更新至最新版。

$ brew cask install java
$ brew install kafka

安装输出:

==> Installing dependencies for kafka: zookeeper
==> Installing kafka dependency: zookeeper
==> Downloading https://homebrew.bintray.com/bottles/zookeeper-3.4.13.mojave.bottle.tar.gz
==> Downloading from https://akamai.bintray.com/d1/d1e4e7738cd147dceb3d91b32480c20ac5da27d129905f336ba51c0c01b8a476?__gda__=exp=1554964702~hmac
######################################################################## 100.0%
==> Pouring zookeeper-3.4.13.mojave.bottle.tar.gz
==> Caveats
To have launchd start zookeeper now and restart at login:
  brew services start zookeeper
Or, if you don't want/need a background service you can just run:
  zkServer start
==> Summary
🍺  /usr/local/Cellar/zookeeper/3.4.13: 244 files, 33.4MB
==> Installing kafka
==> Downloading https://homebrew.bintray.com/bottles/kafka-2.1.1.mojave.bottle.tar.gz
==> Downloading from https://akamai.bintray.com/7c/7c56c9ee176a3ea0dcf9adcd9f01fa6f97597f5320796fb9ce8da6d8c1d0f255?__gda__=exp=1554964853~hmac
######################################################################## 100.0%
==> Pouring kafka-2.1.1.mojave.bottle.tar.gz
==> Caveats
To have launchd start kafka now and restart at login:
  brew services start kafka
Or, if you don't want/need a background service you can just run:
  zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties & kafka-server-start /usr/local/etc/kafka/server.properties
==> Summary
🍺  /usr/local/Cellar/kafka/2.1.1: 162 files, 52.7MB
==> Caveats
==> zookeeper
To have launchd start zookeeper now and restart at login:
  brew services start zookeeper
Or, if you don't want/need a background service you can just run:
  zkServer start
==> kafka
To have launchd start kafka now and restart at login:
  brew services start kafka
Or, if you don't want/need a background service you can just run:
  zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties & kafka-server-start /usr/local/etc/kafka/server.properties
➜  kubernetes-kafka git:(master) brew services start zookeeper
==> Successfully started `zookeeper` (label: homebrew.mxcl.zookeeper)

测试基本功能

新建topic

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

启动producer进程

测试输出

➜  workspace kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
hi,mike zhang

启动consumer进程

➜  workspace kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
hi,mike zhang