checkstyle

lucasbru · lucasbru · commit 169e5e48d7ca · 2025-11-05T14:33:10.000+01:00
diff --git a/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java b/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java
@@ -43,7 +43,7 @@ static ProcessorSupplier<Object, Object, Void, Void> printProcessorSupplier(fina
         return printProcessorSupplier(topic, name, new AtomicInteger());
     }
 
-    static ProcessorSupplier<Object, Object, Void, Void> printProcessorSupplier(final String topic, final String name, AtomicInteger totalRecordsProcessed) {
+    static ProcessorSupplier<Object, Object, Void, Void> printProcessorSupplier(final String topic, final String name, final AtomicInteger totalRecordsProcessed) {
         return () -> new ContextualProcessor<>() {
             private int numRecordsProcessed = 0;
             private long smallestOffset = Long.MAX_VALUE;

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ static ProcessorSupplier<Object, Object, Void, Void> printProcessorSupplier(fina`
`43`	`43`	`return printProcessorSupplier(topic, name, new AtomicInteger());`
`44`	`44`	`}`
`45`	`45`
`46`		`- static ProcessorSupplier<Object, Object, Void, Void> printProcessorSupplier(final String topic, final String name, AtomicInteger totalRecordsProcessed) {`
	`46`	`+ static ProcessorSupplier<Object, Object, Void, Void> printProcessorSupplier(final String topic, final String name, final AtomicInteger totalRecordsProcessed) {`
`47`	`47`	`return () -> new ContextualProcessor<>() {`
`48`	`48`	`private int numRecordsProcessed = 0;`
`49`	`49`	`private long smallestOffset = Long.MAX_VALUE;`