checkstyle and cleanup

Author: mjsax

streams/src/test/java/org/apache/kafka/streams/kstream/RepartitionTopicNamingTest.java

@@ -59,6 +59,7 @@ public class RepartitionTopicNamingTest {
 
     @Test
     public void shouldReuseFirstRepartitionTopicNameWhenOptimizing() {
+
         final String optimizedTopology = buildTopology(StreamsConfig.OPTIMIZE).describe().toString();
         final String unOptimizedTopology = buildTopology(StreamsConfig.NO_OPTIMIZATION).describe().toString();
 

streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphTest.java

@@ -241,7 +241,7 @@ private Topology getTopologyWithChangingValuesAfterChangingKey(final String opti
         mappedKeyStream.processValues(
             () -> new ContextualFixedKeyProcessor<>() {
                 @Override
-                public void process(FixedKeyRecord<String, String> record) {
+                public void process(final FixedKeyRecord<String, String> record) {
                     context().forward(record.withValue(record.value().toUpperCase(Locale.getDefault())));
                 }
             }).groupByKey().count().toStream().to("output");

streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionOptimizingTest.java

@@ -230,7 +230,7 @@ public void shouldNotPushRepartitionAcrossValueChangingOperation() {
             .map((k, v) -> KeyValue.pair(k.toUpperCase(Locale.getDefault()), v))
             .processValues(() -> new ContextualFixedKeyProcessor<String, String, Integer>() {
                 @Override
-                public void process(FixedKeyRecord<String, String> record) {
+                public void process(final FixedKeyRecord<String, String> record) {
                     context().forward(record.withValue(record.value().length()));
                 }
             })