check BOOTSTRAPSERVERS_KEY

Author: yanxi0227

kafka09/kafka09-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceParser.java

@@ -69,7 +69,7 @@ public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, O
         parseFieldsInfo(fieldsInfo, kafka09SourceTableInfo);
 
         kafka09SourceTableInfo.setParallelism(MathUtil.getIntegerVal(props.get(KafkaSourceTableInfo.PARALLELISM_KEY.toLowerCase())));
-        String bootstrapServer = MathUtil.getString(props.get(KafkaSourceTableInfo.GROUPID_KEY.toLowerCase()));
+        String bootstrapServer = MathUtil.getString(props.get(KafkaSourceTableInfo.BOOTSTRAPSERVERS_KEY.toLowerCase()));
         if (bootstrapServer == null || bootstrapServer.trim().equals("")){
             throw new Exception("BootstrapServers can not be empty!");
         } else {

kafka10/kafka10-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceParser.java

@@ -74,7 +74,7 @@ public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, O
 
         kafka10SourceTableInfo.setParallelism(MathUtil.getIntegerVal(props.get(KafkaSourceTableInfo.PARALLELISM_KEY.toLowerCase())));
 
-        String bootstrapServer = MathUtil.getString(props.get(KafkaSourceTableInfo.GROUPID_KEY.toLowerCase()));
+        String bootstrapServer = MathUtil.getString(props.get(KafkaSourceTableInfo.BOOTSTRAPSERVERS_KEY.toLowerCase()));
         if (bootstrapServer == null || bootstrapServer.trim().equals("")){
             throw new Exception("BootstrapServers can not be empty!");
         } else {

kafka11/kafka11-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceParser.java

@@ -73,7 +73,7 @@ public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, O
         parseFieldsInfo(fieldsInfo, kafka11SourceTableInfo);
 
         kafka11SourceTableInfo.setParallelism(MathUtil.getIntegerVal(props.get(KafkaSourceTableInfo.PARALLELISM_KEY.toLowerCase())));
-        String bootstrapServer = MathUtil.getString(props.get(KafkaSourceTableInfo.GROUPID_KEY.toLowerCase()));
+        String bootstrapServer = MathUtil.getString(props.get(KafkaSourceTableInfo.BOOTSTRAPSERVERS_KEY.toLowerCase()));
         if (bootstrapServer == null || bootstrapServer.trim().equals("")){
             throw new Exception("BootstrapServers can not be empty!");
         } else {