Merge branch 'v1.5.0_dev' into v1.5.0_release

Author: zoudaokoulife

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

@@ -121,10 +121,6 @@ public void setOffset(String offset) {
 	public boolean check() {
 		Preconditions.checkNotNull(bootstrapServers, "kafka of bootstrapServers is required");
 		Preconditions.checkNotNull(topic, "kafka of topic is required");
-		//Preconditions.checkNotNull(groupId, "kafka of groupId is required");
-		Preconditions.checkState(offsetReset.equalsIgnoreCase("latest")
-				|| offsetReset.equalsIgnoreCase("earliest"), "kafka of offsetReset set fail");
-
 		return false;
 	}
 

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

@@ -121,10 +121,6 @@ public void setTopicIsPattern(Boolean topicIsPattern) {
     public boolean check() {
         Preconditions.checkNotNull(bootstrapServers, "kafka of bootstrapServers is required");
         Preconditions.checkNotNull(topic, "kafka of topic is required");
-        //Preconditions.checkNotNull(groupId, "kafka of groupId is required");
-        Preconditions.checkState(offsetReset.equalsIgnoreCase("latest")
-                || offsetReset.equalsIgnoreCase("earliest"), "kafka of offsetReset set fail");
-
         return false;
     }
 

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

@@ -122,10 +122,6 @@ public void setOffset(String offset) {
 	public boolean check() {
 		Preconditions.checkNotNull(bootstrapServers, "kafka of bootstrapServers is required");
 		Preconditions.checkNotNull(topic, "kafka of topic is required");
-		//Preconditions.checkNotNull(groupId, "kafka of groupId is required");
-		Preconditions.checkState(offsetReset.equalsIgnoreCase("latest")
-				|| offsetReset.equalsIgnoreCase("earliest"), "kafka of offsetReset set fail");
-
 		return false;
 	}