开发者社区大数据与机器学习实时计算 Flink 正文

有没有小伙伴试过在sink到Kafka的时候让相同的key到Kafka同一个分区？保证相同key是有

有没有小伙伴试过在sink到Kafka的时候让相同的key到Kafka同一个分区？保证相同key是有序的

展开

收起

游客6vdkhpqtie2h2 2022-09-08 11:19:53 1787 版权

2 条回答

写回答

取消提交回答

kunfire

sf

可以设置分区策略来进行分区，可以自定义分区策略。可以参考：https://blog.csdn.net/bwt1989/article/details/93425790 这个看看

2022-09-08 15:15:34

赞同展开评论
游客tk3vic2jx2lk4

默认就是轮询写入。kafka还支持指定写入分区，根据key不同，写入分区不同。（此答案整理自【③群】Apache Flink China社区）

2022-09-08 11:50:05

赞同展开评论

问答分类：

消息中间件 Kafka 实时计算 Flink版云消息队列 Kafka 版

问答标签：

云消息队列 Kafka 版分区 sink云消息队列 Kafka 版云消息队列 Kafka 版sink 云消息队列 Kafka 版key sink云消息队列 Kafka 版分区

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

flink cdc datastream方式同步mysql数据到kafka，多分区怎么保证有序性？

125

B站Kafka动态sink功能如何保证数据一致性？

B站Kafka动态sink功能的实现原理是什么？

B站为什么需要开发Kafka动态sink功能？

B站是如何解决Kafka动态sink问题的？

kafka可以一个topic得多个分区在同一个broker上吗？

213

Flink的作业为啥kafka的消息没有sink到ADB？

DTS是否支持将RDS MySQL表非主键字段作为Partition Key迁移到Kafka

消息队列Kafka版Topic支持多级分区吗

消息队列Kafka版Topic分区数可以减少吗

118

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

千亿消息“过眼云烟”？Kafka把硬盘当内存用的性能魔法，全靠这一手！

从嵌入式状态管理到云原生架构：Apache Flink 的演进与下一代增量计算范式

抖音基于 Flink 的 DataOps 能力实践

即时通讯技术文集（第46期）：微信、QQ技术精华合集(Part3) [共15篇]

有没有小伙伴试过在sink到Kafka的时候让相同的key到Kafka同一个分区？保证相同key是有

实时计算 Flink

相关文章

热门讨论

热门文章