[KAFKA-8040] Streams needs to handle timeout in initTransactions

• Type: Improvement
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 2.0.0, 2.0.1, 2.1.0, 2.2.0, 2.1.1
• Fix Version/s: 2.2.0, 2.0.2, 2.1.2
• Component/s: streams
• Assignee: John Roesler
• Reporter: John Roesler
• Created: 05/Mar/19 00:43
• Updated: 11/Mar/19 22:18
• Resolved: 08/Mar/19 17:03

Description

Following on KAFKA-6446, Streams needs to handle the new behavior.

`initTxn` can throw TimeoutException now: default `MAX_BLOCK_MS_CONFIG` in producer is 60 seconds, so I (guozhang) think just wrapping it as StreamsException should be reasonable, similar to what we do for `producer#send`'s TimeoutException (https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java#L220-L225 ).

 

Issue Links

• is a clone of: KAFKA-7932 Streams needs to handle new Producer exceptions
• is related to: KAFKA-6446 KafkaProducer with transactionId endless waits when bootstrap server is down
• links to: GitHub Pull Request #6372
• links to: GitHub Pull Request #6396
• links to: GitHub Pull Request #6416