[KAFKA-7996] KafkaStreams does not pass timeout when closing Clients

• Type: Bug
• Status: Reopened
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 2.1.0
• Component/s: streams
• Labels: needs-kip new-streams-runtime-should-fix
• Assignee: Unassigned
• Reporter: Patrik Kleindl
• Created: 25/Feb/19 10:02
• Updated: 25/Jun/24 15:04

Description

KIP WIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-459%3A+Improve+KafkaStreams%23close

https://confluentcommunity.slack.com/messages/C48AHTCUQ/convo/C48AHTCUQ-1550831721.026100/

We are running 2.1 and have a case where the shutdown of a streams application takes several minutes
I noticed that although we call streams.close with a timeout of 30 seconds the log says
[Producer clientId=…-8be49feb-8a2e-4088-bdd7-3c197f6107bb-StreamThread-1-producer] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

Matthias J Sax [vor 3 Tagen]
I just checked the code, and yes, we don't provide a timeout for the producer on close()...

We also don't pass in a timeout into admin.close() up to know 3.8 release – we just did a smaller PR to temporarily address this case: https://github.com/apache/kafka/pull/16422 

Issue Links

• links to: GitHub Pull Request #6323