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

• 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: 02/Mar/22 01:46

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()...

Issue Links

• links to: GitHub Pull Request #6323