热门标签
热门文章
- 1实现android的 google第三方登陆！_google跳转浏览器第三方登录 android
- 2git Accessdenied 错误解决办法_git access denied
- 3毕业设计—基于FPGA的极化码译码研究
- 4Github2024-06-12 开源项目日报 Top10
- 5数学推导+纯Python实现机器学习算法：奇异值分解SVD
- 6管理理论的历史演变
- 7Winform中实现连接Mysql8使用mysqldump实现备份表的数据_winfrom mysqldump
- 8Eclipse SVN Merge（合并）的两种方式+TortoiseSVN（小乌龟）合并代码
- 9叮当外卖单体项目SpringBoot+Mybatis-Plus+Redis(附源码)_springboot+redis+mybatisplus+kafka 源码下载
- 10用Python定制一本个性化日历，快来领取你的新年礼物啦~_pyqt6自己布局一个日历
当前位置: article > 正文
流批一体计算引擎-4-[Flink]基于Table API消费kafka实时数据_flink 消费kafka
作者：Guff_9hys | 2024-07-05 05:17:33
赞
踩
flink 消费kafka
Python3.6.9 Flink 1.15.2消费Kafaka Topic
PyFlink基础应用之kafka
通过PyFlink作业处理Kafka数据
1 环境准备
1.1 启动kafka
(1)启动zookeeper
zkServer.sh start
(2)启动kafka
cd /usr/local/kafka/
nohup ./bin/kafka-server-start.sh ./config/server.properties >> /tmp/kafkaoutput.log - 1
- 2
- 3
- 4
- 5
推荐阅读
相关标签
