diff --git a/checkstyle/import-control.xml b/checkstyle/import-control.xml index 7b748eca56f..db1ef7fdbb7 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 e78f96aa5fe..bf289b72954 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; 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 b195093ba3c..b0e19fc4f46 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;