Flink 从 0 到 1 学习（1） Mac 上搭建 Flink 1.6.1 + Kafka3.4环境

1. 环境部署

1.1 安装flink

1. 安装

brew install apache-flink

需要注意授权chmod u+w /usr/local/var/log

2. 检查版本

flink --version

Version: 1.16.1, Commit ID: DeadD0d0

3. 开启

cd /usr/local/Cellar/apache-flink/1.16.1/libexec/bin 
sh ./start-cluster.sh

Starting cluster.
Starting standalonesession daemon on host xxx.local.
Starting taskexecutor daemon on host xxx.local.

4. 页面启动

http://localhost:8081/#/overview

启动效果.png

1.2 安装kafka环境

（1） 环境安装

brew install kafka

• kafka使用zookeeper管理，安装过程会自动安装zookeeper
• 安装目录：/usr/local/Cellar/kafka/* (*为具体安装的版本)
• 配置文件目录：/usr/local/etc/kafka

修改配置：vi /usr/local/etc/kafka/server.properties开启listeners=PLAINTEXT://localhost:9092注释，如下图所示：

开启命令：brew services start kafka

进入这个目录：/usr/local/Cellar/kafka/3.4.0/libexec/bin
发送消息：

sh kafka-console-producer.sh --broker-list localhost:9092 --topic test_topic

接收消息：

sh kafka-console-consumer.sh --bootstrap-server localhost:9092  --topic test_topic --from-beginning

（2）可视化平台下载：

Official website：

https://www.kafkatool.com/

mac下载：

https://www.kafkatool.com/download2/offsetexplorer.dmg

1、点图一左上角图标，进入设置页面，在Add Cluster窗口Properties 选项下填写Cluster name 和 kafka Cluster Version

2. 在Add Cluster窗口Advanced 选项下，填写Bootstrap servers参数，为kafka服务的ip和端口（必填），单点可以不用配置。

3. 可以在平台创建topic：

创建topic.png

相关文档

mac环境下使用brew安装Kafka(详细过程)
【好用推荐】Offset Explorer ： Kafka 客户端管理工具