Dear kafka mangers:
when I use kafka stream Tumbling Window, i found that if the producer
send messages to source topic continuously, the stream TimeWindow could work as
expected. but once i stop the producer, the last window couldn't close, until
the producer send next message. Is this n
Hello,
Yes, this is correct. There is a difference between what we call “stream time”
and regular “wall-clock time”.
All the windowing operations need to be deterministic, otherwise your results
would depend on when you run your program. For that reason, we have “stream
time”, which takes its
Hi Team!
I developed a simple kafka producer & consumer module. Just I want to
acknowledge whether the message is delivered or not. I couldn't find any
document, reference or sample code. Could you please guide me on this?
*Development Language : *Python
Thanks!
Raj
Hello Sandeep,
When using Strimzi and Kafka I created a small app that parses the cert
file and pushes the validity period as a prom metric.
You can run the app periodically in a cron job, you would mount the secret
within the job pod and parse the file.
I was using prom push gateway for that bu