AI 助理
备案控制台
开发者社区 问答 正文

kafka-per-partition 的watermark的分配，可以在keyby之后分配吗？

如题所述，辛苦回答下，感谢！*来自志愿者整理的flink邮件归档

展开
收起
塔塔塔塔塔塔 2021-12-02 17:51:41 958 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • CCCC

    key化就是keyby之后的，个人理解为keyed(key 化)，和您回答的“watermark 可以在 keyBy 后分配”是同一个话题。*来自志愿者整理的FLINK邮件归档

    2021-12-02 18:13:59
    赞同 展开评论
问答分类：
流计算 云消息队列 Kafka 版 实时计算 Flink版
问答标签：
云消息队列 Kafka 版分配 云消息队列 Kafka 版keyby
问答地址：
开发者社区 > 大数据 > 问答
相关问答
Kafka的分区分配算法RangeAssignor是如何工作的？
51
1
0
DataWorks实时同步kafka 并行子任务 是怎么分配消费kafka的任务的。 是什么规则？
244
1
0
kafka Streams如何为每个记录分配时间戳？
568
1
0
kafka中的分区分配策略Range在多生产者的情况下如何做轮询？
635
1
0
kafka中的分区分配策略RoundRobin在多生产者的情况下如何做轮询？
695
1
0
kafka中高级消费者有几种分区分配策略？
530
1
0
kafka的高级消费者的分区分配策略是什么？
574
1
0
flink接收kafka数据,利用keyby做窗口聚合,怎么才能避免数据倾斜 #Flink
2107
1
0
hi 我遇到一个奇怪的问题 有一个10个分区的kafka topic 我的并发度设置成9 有8个分区的数据不消费 并发度设置成8有6个分区数据没法消费 并发度设置成10时 所有分区数据都消费不到，但是从日志上来看 每个task 都分配到了一个partition. 并发度设置成2或者5时 数据消费正常
4190
1
0
有大佬知道这是怎么回事么 flink读不到kafka数据
1136
1
0