Hi.
I am trying to setup custom authentication callback using SASL PLAIN but to be
able to start kafka, it seems I need to provide jaas.config. But why do I need
that when I am using a custom callback handler? What am I missing here?
Also, if I provide a jaas config with properties for KafkaServ
Hello everyone.
I am migrating an application from Flink to Kafka Streams.
I need to generate weekly windowed aggregations, from Monday to Monday.
It does not seem to be possible
https://stackoverflow.com/questions/72785744/how-to-apply-an-offset-to-tumbling-window-in-order-to-delay-the-startin
Hi Matthias, thanks for your reply! Sure, so the use case is as follows.
We currently store some time series data in the state store, and it is stored
to a changelog as well. The time series data is bucketed (5 minutes, 1 hour,
and 1 day). Our goal was to always only have a max of 2 time buckets