[kafka] branch 2.4 updated: HOTFIX: fix checkstyle in Streams system test (#7494)

[guozhang]

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

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


The following commit(s) were added to refs/heads/2.4 by this push:
     new 8e048ba  HOTFIX: fix checkstyle in Streams system test (#7494)
8e048ba is described below

commit 8e048bac4576b0da00d0542a9e848af95c1dea03
Author: A. Sophie Blee-Goldman <sop...@confluent.io>
AuthorDate: Thu Oct 10 19:38:14 2019 -0700

    HOTFIX: fix checkstyle in Streams system test (#7494)
    
    Reviewers: Guozhang Wang <wangg...@gmail.com>
---
 .../kafka/streams/tests/StreamsBrokerDownResilienceTest.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java
index 4dd4954..b605f46 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java
@@ -104,7 +104,7 @@ public class StreamsBrokerDownResilienceTest {
 
         final KafkaStreams streams = new KafkaStreams(builder.build(), 
streamsProperties);
 
-        streams.setUncaughtExceptionHandler( (t,e) -> {
+        streams.setUncaughtExceptionHandler((t, e) -> {
                 System.err.println("FATAL: An unexpected exception " + e);
                 System.err.flush();
                 streams.close(Duration.ofSeconds(30));
@@ -114,11 +114,11 @@ public class StreamsBrokerDownResilienceTest {
         System.out.println("Start Kafka Streams");
         streams.start();
 
-        Runtime.getRuntime().addShutdownHook(new Thread( () -> {
-                streams.close(Duration.ofSeconds(30));
-                System.out.println("Complete shutdown of streams resilience 
test app now");
-                System.out.flush();
-            }
+        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
+            streams.close(Duration.ofSeconds(30));
+            System.out.println("Complete shutdown of streams resilience test 
app now");
+            System.out.flush();
+        }
         ));
     }