root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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
This commit is contained in:
Ewen Cheslack-Postava 2015-09-28 05:58:11 -07:00 committed by Gwen Shapira
parent e90562fb19
commit c20e3bf8d8
3 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
checkstyle/import-control.xml
View File

@ -108,6 +108,7 @@
<allow pkg="org.apache.kafka.clients.consumer" /> <allow pkg="org.apache.kafka.clients.consumer" />
<allow pkg="com.fasterxml.jackson" /> <allow pkg="com.fasterxml.jackson" />
<allow pkg="net.sourceforge.argparse4j" /> <allow pkg="net.sourceforge.argparse4j" />
<allow pkg="org.apache.log4j" />
</subpackage> </subpackage>
</subpackage> </subpackage>

2
tools/src/main/java/org/apache/kafka/clients/tools/VerifiableLog4jAppender.java
View File

@ -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++) { for (long i = 0; i < maxMessages; i++) {
if (appender.stopLogging) { if (appender.stopLogging) {
break; break;

2
tools/src/main/java/org/apache/kafka/clients/tools/VerifiableProducer.java
View File

@ -291,7 +291,7 @@ public class VerifiableProducer {
}); });
ThroughputThrottler throttler = new ThroughputThrottler(producer.throughput, startMs); 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++) { for (long i = 0; i < maxMessages; i++) {
if (producer.stopProducing) { if (producer.stopProducing) {
break; break;