开发者社区> 问答> 正文

partitioner 传 null 是 round-robin 发到每一个partition吗

partitioner 传 null 是 round-robin 发到每一个partition吗

展开
收起
游客qzzytmszf3zhq 2021-12-07 20:21:59 258 0
1 条回答
写回答
取消 提交回答
  • 如果在构造FlinkKafkaProducer时,如果没有设置单独的partitioner,则默认使用FlinkFixedPartitioner,此时无论是带key的数据,还是不带key。如果主动设置partitioner为null时,不带key的数据会round-robin的方式写出,带key的数据会根据key,相同key数据分区的相同的partition,如果key为null,再轮询写。不带key的数据会轮询写各partition。

    2021-12-07 20:22:13
    赞同 展开评论 打赏
问答标签:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
High-throughput Genomics at Your Fingertips with Apache Spark 立即下载
Bulletproof Jobs @ Scale Patterns for Spark Magic 立即下载
Apache Spark at Scale: A 60 TB+ production use case 立即下载