[kafka] branch 2.8 updated: KAFKA-13236: TopologyTestDriver should not crash for EOS-beta config (#11271)

[mjsax]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 2.8
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.8 by this push:
     new 5bdd5bf  KAFKA-13236: TopologyTestDriver should not crash for EOS-beta 
config (#11271)
5bdd5bf is described below

commit 5bdd5bf7306d12d296584e795fc9a44b39cdd1c4
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Fri Aug 27 12:10:56 2021 -0700

    KAFKA-13236: TopologyTestDriver should not crash for EOS-beta config 
(#11271)
    
    Reviewers: Boyang Chen <bche...@outlook.com>
---
 .../src/main/java/org/apache/kafka/streams/TopologyTestDriver.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
 
b/streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
index 35bae58..83980c9 100644
--- 
a/streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
+++ 
b/streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
@@ -1423,7 +1423,7 @@ public class TopologyTestDriver implements Closeable {
         public TestDriverProducer(final StreamsConfig config,
                                   final KafkaClientSupplier clientSupplier,
                                   final LogContext logContext) {
-            super(config, "TopologyTestDriver-Thread", clientSupplier, new 
TaskId(0, 0), UUID.randomUUID(), logContext);
+            super(config, "TopologyTestDriver-StreamThread-1", clientSupplier, 
new TaskId(0, 0), UUID.randomUUID(), logContext);
         }
 
         @Override