[kafka] branch 2.7 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.7
in repository https://gitbox.apache.org/repos/asf/kafka.git


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

commit 46002bbdab98d4d8e5f43abdb0a6185a5f8fb594
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