Flink 消费Kafka Window不触发计算怎么办呢?

Flink 消费Kafka, 有的并发没数据,导致Watermark不更新,进而Window不触发计算。 请教下: 像这种情况,一般解决方式有那些? *来自志愿者整理的flink邮件归档

flink消费kafka,计算完再写回kafka,目前kafka sink 只支持 #Flink

flink消费kafka,计算完再写回kafka,目前kafka sink 只支持append,这种有好的办法吗?#Flink

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图

请问下窗口计算能对历史数据进行处理吗?比如kafka里的写数据没停,窗口计算的应用停掉一段时间再开起

请问下窗口计算能对历史数据进行处理吗?比如kafka里的写数据没停,窗口计算的应用停掉一段时间再开起来,停掉的那段时间生成的数据是不是就没法计算了,窗口计算是基于当前时间进行统计吧? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

Kafka分区分配计算(分区器Partitions)

KafkaProducer在调用send方法发送消息至broker的过程中,首先是经过拦截器Inteceptors处理,然后是经过序列化Serializer处理,之后就到了Partitions阶段,即分区分配计算阶段。在某些应用场景下,业务逻辑需要控制每条消息落到合适的分区中,有些情形下则只要根据默...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。