adjust format

apache · Mar 17, 2021 · dc9db2c · dc9db2c
1 parent 2d55215
commit dc9db2c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...nectors/flink-connector-kafka/src/main/java/org/apache/flink/table/descriptors/Kafka.java b/...nectors/flink-connector-kafka/src/main/java/org/apache/flink/table/descriptors/Kafka.java
@@ -94,7 +94,8 @@ public Kafka properties(Properties properties) {
             this.kafkaProperties = new HashMap<>();
         }
         this.kafkaProperties.clear();
-        properties.forEach((k, v) -> this.kafkaProperties.put(String.valueOf(k), String.valueOf(v)));
+        properties.forEach(
+                (k, v) -> this.kafkaProperties.put(String.valueOf(k), String.valueOf(v)));
         return this;
     }