Repository: kafka Updated Branches: refs/heads/trunk e90562fb1 -> c20e3bf8d
HOTFIX: Checkstye fixes follow up for KAKFA-2531. Author: Ewen Cheslack-Postava <[email protected]> Reviewers: Gwen Shapira Closes #248 from ewencp/hotfix-kafka-2531-checkstyle Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c20e3bf8 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c20e3bf8 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c20e3bf8 Branch: refs/heads/trunk Commit: c20e3bf8d81330407cbbb5445a9f294d3df7a821 Parents: e90562f Author: Ewen Cheslack-Postava <[email protected]> Authored: Mon Sep 28 05:58:11 2015 -0700 Committer: Gwen Shapira <[email protected]> Committed: Mon Sep 28 05:58:11 2015 -0700 ---------------------------------------------------------------------- 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(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/c20e3bf8/checkstyle/import-control.xml ---------------------------------------------------------------------- diff --git a/checkstyle/import-control.xml b/checkstyle/import-control.xml index 7b748ec..db1ef7f 100644 --- a/checkstyle/import-control.xml +++ b/checkstyle/import-control.xml @@ -108,6 +108,7 @@ <allow pkg="org.apache.kafka.clients.consumer" /> <allow pkg="com.fasterxml.jackson" /> <allow pkg="net.sourceforge.argparse4j" /> + <allow pkg="org.apache.log4j" /> </subpackage> </subpackage> http://git-wip-us.apache.org/repos/asf/kafka/blob/c20e3bf8/tools/src/main/java/org/apache/kafka/clients/tools/VerifiableLog4jAppender.java ---------------------------------------------------------------------- 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 e78f96a..bf289b7 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; http://git-wip-us.apache.org/repos/asf/kafka/blob/c20e3bf8/tools/src/main/java/org/apache/kafka/clients/tools/VerifiableProducer.java ---------------------------------------------------------------------- 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 b195093..b0e19fc 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;
