kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: HOTFIX: Checkstye fixes follow up for KAKFA-2531.
Date Mon, 28 Sep 2015 12:58:26 GMT
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 <cshapi@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;


Mime
View raw message