Hello,

Is there a good way to calculate an efficient timeout for the 
KafkaStreams#close(Duration) method?
I’ve experienced some problem with my stream application because the timeout 
was too low but I also don’t want to set a timeout that’s bigger than the 
necessary.

Currently, I’m calculating it based on the partition count of the topic that 
the stream application reads from (e.g. 1 second for every partition), but I’m 
curious if there’s a better, time-tested way to do that.

Best regards,
Kaloyan

Reply via email to