[KAFKA-13236] TopologyTestDriver crashes with EOS-beta config

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 2.6.0, 2.7.0, 2.8.0
• Fix Version/s: 2.6.3, 2.7.2, 2.8.1
• Component/s: streams-test-utils
• Assignee: Matthias J. Sax
• Reporter: Matthias J. Sax
• Created: 27/Aug/21 00:55
• Updated: 28/Aug/21 03:15
• Resolved: 27/Aug/21 20:23

Description

If EOS-beta is configured, we rely on the `-StreamThread` name part to create `StreamsProducer`. (cf https://github.com/apache/kafka/commit/20e4a74c3579837df7b46ce1a5dcea37b6e1e452) However, TopologyTestDriver sets the name only as `-Thread` and thus it crashed for EOS-beta is configured.

The issue is already fixed in 3.0 via https://github.com/apache/kafka/commit/3805f3706f8f3ebba81b80915c9259590525fb05 but we should still fix it for older release, too.

Issue Links

• links to: GitHub Pull Request #11271
• links to: GitHub Pull Request #11279