¿Cómo administrar Kafka KStream a Kstream con ventana?
Residencia enApache Kafka docs KStream-to-KStream Joins are always windowed joins
, mi pregunta es ¿cómo puedo controlar el tamaño de la ventana? ¿Es del mismo tamaño para mantener los datos sobre el tema? O, por ejemplo, ¿podemos conservar los datos durante 1 mes pero unirnos a la transmisión solo la semana pasada?
¿Hay algún buen ejemplo para mostrar una unión en ventana KStream-to-kStream en ventana?
En mi caso, digamos que tengo 2 KStream,kstream1
ykstream2
Quiero poder unirme a 10 días dekstream1
a 30 días dekstream2
.