You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gw...@apache.org on 2015/09/28 14:58:26 UTC
kafka git commit: HOTFIX: Checkstye fixes follow up for KAKFA-2531.
Repository: kafka
Updated Branches:
refs/heads/trunk e90562fb1 -> c20e3bf8d
HOTFIX: Checkstye fixes follow up for KAKFA-2531.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
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 <me...@ewencp.org>
Authored: Mon Sep 28 05:58:11 2015 -0700
Committer: Gwen Shapira <cs...@gmail.com>
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;