Fix comma formatting for mkKafkaReadTransform.

Author: tomstepp

sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOReadImplementationCompatibilityTest.java

@@ -116,7 +116,7 @@ private PipelineResult testReadTransformCreationWithImplementationBoundPropertie
                 false, /*allowDuplicates*/
                 0, /*numKeys*/
                 null, /*offsetDeduplication*/
-                null /*topics*/,
+                null, /*topics*/
                 null /*redistributeByRecordKey*/)));
     return p.run();
   }

sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java

@@ -394,7 +394,7 @@ static KafkaIO.Read<Integer, Long> mkKafkaReadTransform(
         false, /*allowDuplicates*/
         0, /*numKeys*/
         null, /*offsetDeduplication*/
-        null /*topics*/,
+        null, /*topics*/
         null /*redistributeByRecordKey*/);
   }
 
@@ -408,7 +408,7 @@ static KafkaIO.Read<Integer, Long> mkKafkaReadTransformWithOffsetDedup(
         false, /*allowDuplicates*/
         100, /*numKeys*/
         true, /*offsetDeduplication*/
-        null /*topics*/,
+        null, /*topics*/
         null /*redistributeByRecordKey*/);
   }
 
@@ -424,7 +424,7 @@ static KafkaIO.Read<Integer, Long> mkKafkaReadTransformWithRedistributeByRecordK
         false, /*allowDuplicates*/
         100, /*numKeys*/
         true, /*offsetDeduplication*/
-        null /*topics*/,
+        null, /*topics*/
         byRecordKey /*redistributeByRecordKey*/);
   }
 
@@ -440,7 +440,7 @@ static KafkaIO.Read<Integer, Long> mkKafkaReadTransformWithTopics(
         false, /*allowDuplicates*/
         0, /*numKeys*/
         null, /*offsetDeduplication*/
-        topics /*topics*/,
+        topics, /*topics*/
         null /*redistributeByRecordKey*/);
   }
 
@@ -745,7 +745,7 @@ public void warningsWithAllowDuplicatesEnabledAndCommitOffsets() {
                         true, /*allowDuplicates*/
                         0, /*numKeys*/
                         null, /*offsetDeduplication*/
-                        null /*topics*/,
+                        null, /*topics*/
                         null /*redistributeByRecordKey*/)
                     .commitOffsetsInFinalize()
                     .withConsumerConfigUpdates(
@@ -774,7 +774,7 @@ public void noWarningsWithNoAllowDuplicatesAndCommitOffsets() {
                         false, /*allowDuplicates*/
                         0, /*numKeys*/
                         null, /*offsetDeduplication*/
-                        null /*topics*/,
+                        null, /*topics*/
                         null /*redistributeByRecordKey*/)
                     .commitOffsetsInFinalize()
                     .withConsumerConfigUpdates(
@@ -804,7 +804,7 @@ public void testNumKeysIgnoredWithRedistributeNotEnabled() {
                         false, /*allowDuplicates*/
                         0, /*numKeys*/
                         null, /*offsetDeduplication*/
-                        null /*topics*/,
+                        null, /*topics*/
                         null /*redistributeByRecordKey*/)
                     .withRedistributeNumKeys(100)
                     .commitOffsetsInFinalize()
@@ -2178,7 +2178,7 @@ public void testUnboundedSourceStartReadTime() {
                         false, /*allowDuplicates*/
                         0, /*numKeys*/
                         null, /*offsetDeduplication*/
-                        null /*topics*/,
+                        null, /*topics*/
                         null /*redistributeByRecordKey*/)
                     .withStartReadTime(new Instant(startTime))
                     .withoutMetadata())
@@ -2255,7 +2255,7 @@ public void testUnboundedSourceStartReadTimeException() {
                     false, /*allowDuplicates*/
                     0, /*numKeys*/
                     null, /*offsetDeduplication*/
-                    null /*topics*/,
+                    null, /*topics*/
                     null /*redistributeByRecordKey*/)
                 .withStartReadTime(new Instant(startTime))
                 .withoutMetadata())