(inlong) branch master updated: [INLONG-9285][Manager] When creating KafkaSource, the autoOffsetReset param cannot be empty (#9287)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 47ff34981b [INLONG-9285][Manager] When creating KafkaSource, the 
autoOffsetReset param cannot be empty (#9287)
47ff34981b is described below

commit 47ff34981bcbf3025e10644a9b6faa6168ac9b11
Author: LiJie20190102 <53458004+lijie20190...@users.noreply.github.com>
AuthorDate: Mon Nov 20 11:37:04 2023 +0800

    [INLONG-9285][Manager] When creating KafkaSource, the autoOffsetReset param 
cannot be empty (#9287)
    
    Co-authored-by: lijie0203 <li...@qishudi.com>
---
 .../java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java
index 0ccb0b45aa..7140496ed5 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java
@@ -67,7 +67,7 @@ public class KafkaSource extends StreamSource {
     private String timestampMillis;
 
     @ApiModelProperty(value = "The strategy of auto offset reset", notes = 
"including earliest, specific, latest (the default), none")
-    private String autoOffsetReset;
+    private String autoOffsetReset = KafkaOffset.LATEST.getName();
 
     @ApiModelProperty("database pattern used for filter in canal format")
     private String databasePattern;