网站介绍：文章浏览阅读2.5k次。1-参数设置以下参数都必须/建议设置上1.订阅的主题2.反序列化规则3.消费者属性-集群地址4.消费者属性-消费者组id(如果不设置,会有默认的,但是默认的不方便管理)5.消费者属性-offset重置规则,如earliest/latest…6.动态分区检测(当kafka的分区数变化/增加时,Flink能够检测到!)7.Checkpoint会把offset随着做Checkpoint的时候提交到Checkpoint和默认主题中2- 参数说明注意:实际的生产环境中可能有这样一些需求_flink api返回kafka数据流入量
- 链接地址：https://blog.csdn.net/m0_49834705/article/details/119381061
- 链接标题：Flink Connectors之消费Kafka数据相关参数以及API说明_flink api返回kafka数据流入量-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：637
- 网站标签：flink api返回kafka数据流入量
