code format

Author: todd5167

kafka09/kafka09-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/KafkaSink.java

@@ -64,7 +64,7 @@ public KafkaSink genStreamSink(TargetTableInfo targetTableInfo) {
 		this.fieldTypes = types;
 
 		properties = new Properties();
-		for (String key:kafka09SinkTableInfo.getKafkaParamKeys()) {
+		for (String key : kafka09SinkTableInfo.getKafkaParamKeys()) {
 			properties.setProperty(key, kafka09SinkTableInfo.getKafkaParam(key));
 		}
 		properties.setProperty("bootstrap.servers", kafka09SinkTableInfo.getBootstrapServers());

kafka09/kafka09-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkParser.java

@@ -42,7 +42,7 @@ public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, O
 
         kafka09SinkTableInfo.setBootstrapServers(MathUtil.getString(props.get(KafkaSinkTableInfo.BOOTSTRAPSERVERS_KEY.toLowerCase())));
         kafka09SinkTableInfo.setTopic(MathUtil.getString(props.get(KafkaSinkTableInfo.TOPIC_KEY.toLowerCase())));
-        for (String key:props.keySet()) {
+        for (String key : props.keySet()) {
             if (!key.isEmpty() && key.startsWith("kafka.")) {
                 kafka09SinkTableInfo.addKafkaParam(key.substring(6), props.get(key).toString());
             }

kafka10/kafka10-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/KafkaSink.java

@@ -69,7 +69,7 @@ public KafkaSink genStreamSink(TargetTableInfo targetTableInfo) {
         this.fieldTypes = types;
 
         properties = new Properties();
-        for (String key:kafka10SinkTableInfo.getKafkaParamKeys()) {
+        for (String key : kafka10SinkTableInfo.getKafkaParamKeys()) {
             properties.setProperty(key, kafka10SinkTableInfo.getKafkaParam(key));
         }
         properties.setProperty("bootstrap.servers", kafka10SinkTableInfo.getBootstrapServers());

kafka10/kafka10-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkParser.java

@@ -42,7 +42,7 @@ public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, O
 
         kafka10SinkTableInfo.setBootstrapServers(MathUtil.getString(props.get(KafkaSinkTableInfo.BOOTSTRAPSERVERS_KEY.toLowerCase())));
         kafka10SinkTableInfo.setTopic(MathUtil.getString(props.get(KafkaSinkTableInfo.TOPIC_KEY.toLowerCase())));
-        for (String key:props.keySet()) {
+        for (String key : props.keySet()) {
             if (!key.isEmpty() && key.startsWith("kafka.")) {
                 kafka10SinkTableInfo.addKafkaParam(key.substring(6), props.get(key).toString());
             }

kafka11/kafka11-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/KafkaSink.java

@@ -67,7 +67,7 @@ public KafkaSink genStreamSink(TargetTableInfo targetTableInfo) {
         this.fieldTypes = types;
 
         properties = new Properties();
-        for (String key:kafka11SinkTableInfo.getKafkaParamKeys()) {
+        for (String key : kafka11SinkTableInfo.getKafkaParamKeys()) {
             properties.setProperty(key, kafka11SinkTableInfo.getKafkaParam(key));
         }
         properties.setProperty("bootstrap.servers", kafka11SinkTableInfo.getBootstrapServers());

kafka11/kafka11-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkParser.java

@@ -42,7 +42,7 @@ public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, O
 
         kafka11SinkTableInfo.setBootstrapServers(MathUtil.getString(props.get(KafkaSinkTableInfo.BOOTSTRAPSERVERS_KEY.toLowerCase())));
         kafka11SinkTableInfo.setTopic(MathUtil.getString(props.get(KafkaSinkTableInfo.TOPIC_KEY.toLowerCase())));
-        for (String key:props.keySet()) {
+        for (String key : props.keySet()) {
             if (!key.isEmpty() && key.startsWith("kafka.")) {
                 kafka11SinkTableInfo.addKafkaParam(key.substring(6), props.get(key).toString());
             }