【Kafka】（三）Mac 上 Kakfa 的初体验

环境准备：

1、安装 HomeBrew （https://brew.sh/）

打开终端，直接输入即可完成安装：

Shell

/usr/bin/ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)"

2、配置 Java 环境

参考：Mac电脑上配置Java开发环境

安装 Kafka:

打开终端，输入下面命令:

Shell

// 安装过程将依赖安装 zookeeper brew install kafka

软件位置：

• /usr/local/Cellar/zookeeper
• /usr/local/Cellar/kafka

配置文件位置：

• /usr/local/etc/kafka/zookeeper.properties
• /usr/local/etc/kafka/server.properties

启动 Kafka && 启动 Zookeeper：

Shell

brew services start kafka

如果你不想有一个在后台运行着的服务，你可以用下面这个命令：

Shell

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

Kafka 初体验：

创建 topic： 

在这里我们创建只有一个分区（Partition）只有一个副本（Replica）名字叫做 test 的 Topic：

Shell

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

查看 topic 列表：

Shell

kafka-topics --list --zookeeper localhost:2181

尝试发送一些消息：

Kafka提供了一个命令行客户端，它将从文件或标准输入接收输入，并将其作为消息发送到Kafka集群。默认情况下，每行都将作为单独的消息发送。 运行生产者，然后在控制台中键入一些消息发送到服务器。

Shell

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

尝试消费消息：

Kafka还有一个命令行消费者，将消息转储到标准输出。以下是我们从开头消费 test 的消息。 期间一些空白的地方，是由于我们发送的消息就是空白。

Shell

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

喜欢(1) 打赏