Trying to setup custom authentication callback handler using SASL PLAIN

2023-01-18 Thread Bjørn T Johansen
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

Offset for Tumbling Windows

2023-01-18 Thread Amsterdam Luís de Lima Filho
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

Re: Custom Kafka Streams State Restore Logic

2023-01-18 Thread Upesh Desai
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