fix kafka offset bug

Author: zoudaokoulife

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

@@ -123,7 +123,7 @@ public boolean check() {
 		Preconditions.checkNotNull(topic, "kafka of topic is required");
 		//Preconditions.checkNotNull(groupId, "kafka of groupId is required");
 		Preconditions.checkState(offsetReset.equalsIgnoreCase("latest")
-				|| offsetReset.equalsIgnoreCase("latest"), "kafka of offsetReset set fail");
+				|| 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

@@ -123,7 +123,7 @@ public boolean check() {
         Preconditions.checkNotNull(topic, "kafka of topic is required");
         //Preconditions.checkNotNull(groupId, "kafka of groupId is required");
         Preconditions.checkState(offsetReset.equalsIgnoreCase("latest")
-                || offsetReset.equalsIgnoreCase("latest"), "kafka of offsetReset set fail");
+                || 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

@@ -124,7 +124,7 @@ public boolean check() {
 		Preconditions.checkNotNull(topic, "kafka of topic is required");
 		//Preconditions.checkNotNull(groupId, "kafka of groupId is required");
 		Preconditions.checkState(offsetReset.equalsIgnoreCase("latest")
-				|| offsetReset.equalsIgnoreCase("latest"), "kafka of offsetReset set fail");
+				|| offsetReset.equalsIgnoreCase("earliest"), "kafka of offsetReset set fail");
 
 		return false;
 	}