From 7bf44cc4790cc9989ece2e904bf843de3b6aeb90 Mon Sep 17 00:00:00 2001 From: Ewen Cheslack-Postava Date: Mon, 28 Sep 2015 02:18:22 -0400 Subject: [PATCH] HOTFIX: Checkstye fixes follow up for KAKFA-2531. --- 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 7b748eca56f8a..db1ef7fdbb784 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 e78f96aa5fea7..bf289b72954db 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 void run() { } }); - 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 b195093ba3c9b..b0e19fc4f46eb 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 void run() { }); 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;