关注
码龄
粉丝数
原力等级 --
被采纳
被点赞
采纳率
挟飞仙以遨游,抱明月而长终
2021-08-16 15:59
采纳率: 100%
浏览 23
首页
有问必答
已结题
关于flink接收kafka消息的代码能不能用python写
有问必答
python
flink
kafka
关于flink接收kafka消息的代码能不能用python写
写回答
好问题
提建议
追加酬金
关注问题
微信扫一扫
点击复制链接
分享
邀请回答
1
条回答
默认
最新
相关推荐
更多相似问题
关于
flink
接收
kafka
消息
的
代码
能
不能
用
python
写
flink
kafka
python
有问必答
2021-08-16 15:59
回答 1
已采纳
应该可以,不过通常使
用
scala语言进行编
写
关于
Flink
接收
Kafka
流数据使
用
Table API和SQL处理的问题
flink
有问必答
2021-08-18 11:07
回答 2
已采纳
你的包是不是导错了。删除你导入的包,把下面的包复制放你程序中。 import org.apache.
flink
.api.common.typeinfo.TypeInformation; import
flink
消费
kafka
数据延迟
flink
postgresql
scala
有问必答
2022-01-28 09:47
回答 1
已采纳
那最后
写
入到库了吗,如果
写
不进去,上游
kafka
肯定会延迟越来越大的,可以在sink里多打印下错误,或者设置
写
入超时时间,问题应该在
写
入
python
flink
kafka
_
Flink
with
Kafka
2020-12-29 07:31
嘿bro的博客
How Apache
Flink
manages
Kafka
consumer offsetsStep 1:例子:一个
kafka
topic,有两个partition,每个含有"A,B,C,D,E"信息。offset从0开始。Step 1Step 2:第二步,
kafka
consumer开始从partition 0开始读取信息...
pylink链接
kafka
资源jar包
flink
-connector-
kafka
_2.12-1.11.0
2020-12-04 15:12
flink
-connector-
kafka
_2.12-1.11.0.jar pylink链接
kafka
资源jar包f
没有解决我的问题,
去提问