[hotfix-394][kb] 解决earliest-offset不生效问题

zhongjiang.mu · kanata163 · commit 8638bf7d4471 · 2021-05-24T20:45:00.000+08:00
diff --git a/flinkx-kb/flinkx-kb-core/src/main/java/com/dtstack/flinkx/kafkabase/util/KafkaUtil.java b/flinkx-kb/flinkx-kb-core/src/main/java/com/dtstack/flinkx/kafkabase/util/KafkaUtil.java
@@ -95,6 +95,7 @@ public static Properties geneConsumerProp(Map<String, String> consumerSettings,
         switch (mode){
             case EARLIEST:
                 props.put("auto.offset.reset", "earliest");
+                break;
             case LATEST:
                 props.put("auto.offset.reset", "latest");
         }

Original file line number	Diff line number	Diff line change
`@@ -95,6 +95,7 @@ public static Properties geneConsumerProp(Map<String, String> consumerSettings,`
`95`	`95`	`switch (mode){`
`96`	`96`	`case EARLIEST:`
`97`	`97`	`props.put("auto.offset.reset", "earliest");`
	`98`	`+ break;`
`98`	`99`	`case LATEST:`
`99`	`100`	`props.put("auto.offset.reset", "latest");`
`100`	`101`	`}`