Kafka安装 for mac

mac系统安装使用kafka

Posted by Oumuv on December 6, 2018

环境要求

  • kafka2
  • mac(linux系统操作大同小异)

步骤

下载安装

Mac系统中可以使用brew工具,只需要一条命令就完成了下载与安装的过程,关于brew安装–>Mac安装brew

brew install kafka

等待安装完成后可以看到kafka安装路径和kafka配置文件的路径:

/usr/local/Cellar/kafka/2.1.0 /usr/local/etc/kafka/

启动kafka

kafka依赖zookeeper,而kafka中默认已有一个单机版的zookeeper供使用(实际生产环境中不推荐使用默认的zookeeper)

  1. 开启zookeeper
  • cd到kafka的安装目录下

    cd /usr/local/Cellar/kafka/2.1.0

  • 执行脚本启动zookeeper:

    bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties

/usr/local/etc/kafka/zookeeper.properties 是zookeeper的配置文件,启动成功如下图:

  1. 启动kafka
  • 再打开一个控制窗口,cd到kafka的安装目录下

    cd /usr/local/Cellar/kafka/2.1.0

  • 执行脚本启动kafka:

    bin/kafka-server-start /usr/local/etc/kafka/server.properties

测试

  1. 首先创建一个主题(topic)

再打开一个控制窗口,cd到kafka的安装目录下

cd /usr/local/Cellar/kafka/2.1.0

执行命令,创建一个主题

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

–create 创建主题命令
–zookeeper localhost:2181 指定zookeeper
–replication-factor 1 指定副本个数
–partitions 1 指定分区个数
–topic test 主题名称为“test”

查看是否成功创建主题

bin/kafka-topics –list –zookeeper localhost:2181

  1. 测试生产者(producer)与消费者(consumer)

打开一个窗口输入命令创建一个生产者:

bin/kafka-console-producer –broker-list localhost:9092 –topic test

打开一个窗口输入命令创建一个消费者:

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

使用生产者发送消息,消费者接受消息

测试成功