You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2021/08/28 03:16:22 UTC
[kafka] branch 2.6 updated: KAFKA-13236: TopologyTestDriver should
not crash for EOS-beta config (#11279)
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 <ma...@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 <so...@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