[kafka] branch 2.7 updated: HOTFIX: fix build in EmitOnChangeIntegrationTest (#10364)

[ableegoldman]

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

ableegoldman 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 51a66ee  HOTFIX: fix build in EmitOnChangeIntegrationTest (#10364)
51a66ee is described below

commit 51a66ee3ebf09c956fdac33d8e8087071ad34ce7
Author: A. Sophie Blee-Goldman <sop...@confluent.io>
AuthorDate: Fri Mar 19 19:09:22 2021 -0700

    HOTFIX: fix build in EmitOnChangeIntegrationTest (#10364)
---
 .../apache/kafka/streams/integration/EmitOnChangeIntegrationTest.java | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/integration/EmitOnChangeIntegrationTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/integration/EmitOnChangeIntegrationTest.java
index 79454ec..9ce8f14 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/integration/EmitOnChangeIntegrationTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/integration/EmitOnChangeIntegrationTest.java
@@ -25,7 +25,6 @@ import org.apache.kafka.streams.KafkaStreams;
 import org.apache.kafka.streams.KeyValue;
 import org.apache.kafka.streams.StreamsBuilder;
 import org.apache.kafka.streams.StreamsConfig;
-import 
org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse;
 import org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster;
 import org.apache.kafka.streams.integration.utils.IntegrationTestUtils;
 import org.apache.kafka.streams.kstream.Materialized;
@@ -77,7 +76,7 @@ public class EmitOnChangeIntegrationTest {
                 mkEntry(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, 
CLUSTER.bootstrapServers()),
                 mkEntry(StreamsConfig.APPLICATION_ID_CONFIG, appId),
                 mkEntry(StreamsConfig.STATE_DIR_CONFIG, 
TestUtils.tempDirectory().getPath()),
-                mkEntry(StreamsConfig.NUM_STREAM_THREADS_CONFIG, 1),
+                mkEntry(StreamsConfig.NUM_STREAM_THREADS_CONFIG, 2),
                 mkEntry(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0),
                 mkEntry(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 300000),
                 mkEntry(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, 
Serdes.IntegerSerde.class),
@@ -99,7 +98,6 @@ public class EmitOnChangeIntegrationTest {
             .to(outputTopic);
 
         try (final KafkaStreams kafkaStreams = new 
KafkaStreams(builder.build(), properties)) {
-            kafkaStreams.setUncaughtExceptionHandler(exception -> 
StreamThreadExceptionResponse.REPLACE_THREAD);
             
StreamsTestUtils.startKafkaStreamsAndWaitForRunningState(kafkaStreams);
 
             IntegrationTestUtils.produceKeyValuesSynchronouslyWithTimestamp(