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

[mjsax]

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

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


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

commit 41d858081985dd71d4dfaa1877e65e5c2e0da2e6
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Fri Aug 27 19:40:05 2021 -0700

    KAFKA-13236: TopologyTestDriver should not crash for EOS-beta config 
(#11279)
    
    Reviewer: A. Sophie Blee-Goldman <sop...@confluent.io>
---
 .../apache/kafka/streams/processor/internals/TestDriverProducer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals/TestDriverProducer.java
 
b/streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals/TestDriverProducer.java
index 14e5e135..95530f7 100644
--- 
a/streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals/TestDriverProducer.java
+++ 
b/streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals/TestDriverProducer.java
@@ -33,7 +33,7 @@ public class TestDriverProducer extends StreamsProducer {
     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