From c20e3bf8d81330407cbbb5445a9f294d3df7a821 Mon Sep 17 00:00:00 2001 From: Ewen Cheslack-Postava Date: Mon, 28 Sep 2015 05:58:11 -0700 Subject: [PATCH] HOTFIX: Checkstye fixes follow up for KAKFA-2531. Author: Ewen Cheslack-Postava Reviewers: Gwen Shapira Closes #248 from ewencp/hotfix-kafka-2531-checkstyle --- checkstyle/import-control.xml | 1 + .../org/apache/kafka/clients/tools/VerifiableLog4jAppender.java | 2 +- .../java/org/apache/kafka/clients/tools/VerifiableProducer.java | 2 +- 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/checkstyle/import-control.xml b/checkstyle/import-control.xml index 7b748eca56f..db1ef7fdbb7 100644 --- a/checkstyle/import-control.xml +++ b/checkstyle/import-control.xml @@ -108,6 +108,7 @@ + diff --git a/tools/src/main/java/org/apache/kafka/clients/tools/VerifiableLog4jAppender.java b/tools/src/main/java/org/apache/kafka/clients/tools/VerifiableLog4jAppender.java index e78f96aa5fe..bf289b72954 100644 --- a/tools/src/main/java/org/apache/kafka/clients/tools/VerifiableLog4jAppender.java +++ b/tools/src/main/java/org/apache/kafka/clients/tools/VerifiableLog4jAppender.java @@ -147,7 +147,7 @@ public class VerifiableLog4jAppender { } }); - long maxMessages = infinite ? Long.MAX_VALUE: appender.maxMessages; + long maxMessages = infinite ? Long.MAX_VALUE : appender.maxMessages; for (long i = 0; i < maxMessages; i++) { if (appender.stopLogging) { break; diff --git a/tools/src/main/java/org/apache/kafka/clients/tools/VerifiableProducer.java b/tools/src/main/java/org/apache/kafka/clients/tools/VerifiableProducer.java index b195093ba3c..b0e19fc4f46 100644 --- a/tools/src/main/java/org/apache/kafka/clients/tools/VerifiableProducer.java +++ b/tools/src/main/java/org/apache/kafka/clients/tools/VerifiableProducer.java @@ -291,7 +291,7 @@ public class VerifiableProducer { }); ThroughputThrottler throttler = new ThroughputThrottler(producer.throughput, startMs); - long maxMessages = infinite ? Long.MAX_VALUE: producer.maxMessages; + long maxMessages = infinite ? Long.MAX_VALUE : producer.maxMessages; for (long i = 0; i < maxMessages; i++) { if (producer.stopProducing) { break;