Confluent 视频上门面经

你方便说说windowed processor吗？我看kafka源码，找到这个
https://kafka.apache.org/26/java ... te/WindowStore.html

https://github.com/apache/kafka/ ... oryWindowStore.java

存进去的时候记录时间，用时间作为key的map？Map<long, Map<K, V>> 是这个意思吗？

匿名者 发表于 2021-3-18 06:41
面了哪个组哇？我也是昨天刚面

你好，你面试都顺利吗？我下周面试，方便交流一下吗？

木公想出国 发表于 2021-3-14 14:42
用单线程实现delay scheduler, 是不是就是用Thread.sleep(delayTime) , 然后再run task?
后天面试Confl ...

同问！！