Flink 从 0 到 1 学习（1） Mac 上搭建 Flin
2023-04-13 本文已影响0人
小胖学编程
1. 环境部署
1.1 安装flink
- 安装
brew install apache-flink
需要注意授权chmod u+w /usr/local/var/log
- 检查版本
flink --version
Version: 1.16.1, Commit ID: DeadD0d0
- 开启
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.
- 页面启动
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注释，如下图所示：
image.png
开启命令：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：
mac下载：
https://www.kafkatool.com/download2/offsetexplorer.dmg
1、点图一左上角图标，进入设置页面，在Add Cluster窗口Properties 选项下填写Cluster name 和 kafka Cluster Version
image.png
- 在Add Cluster窗口Advanced 选项下，填写Bootstrap servers参数，为kafka服务的ip和端口（必填），单点可以不用配置。
image.png
- 可以在平台创建topic：
创建topic.png
相关文档
mac环境下使用brew安装Kafka(详细过程)
【好用推荐】Offset Explorer ： Kafka 客户端管理工具
