网站首页 站内搜索

搜索结果

查询Tags标签: FlinkFixedPartitioner,共有 1条记录
  • flink sink到kafka 默认分区器 FlinkFixedPartitioner相关源码分析

    1、flink和kafka交互有两种jar包: 通过maven仓库搜索 https://mvnrepository.com/search?q=org.apache.flink+++flink-connector-kafka-老的jar包有三种: 0.11版本(只更新到1.11.x):<dependency><groupId>org.apache.flink</groupId><artifactId&…

    2021/4/29 22:25:08 人评论 次浏览
扫一扫关注最新编程教程