lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-663] Fix HoodieDeltaStreamer offset not handled correctly (#1377)

Browse Source
This commit is contained in:
lamber-ken
2020-03-22 12:31:48 -05:00
committed by GitHub
parent 1e1d9e1d34
commit 38c3ccc51a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java
View File

@@ -180,7 +180,7 @@ public class KafkaOffsetGen {
.map(x -> new TopicPartition(x.topic(), x.partition())).collect(Collectors.toSet()); .map(x -> new TopicPartition(x.topic(), x.partition())).collect(Collectors.toSet());
// Determine the offset ranges to read from // Determine the offset ranges to read from
if (lastCheckpointStr.isPresent()) { if (lastCheckpointStr.isPresent() && !lastCheckpointStr.get().isEmpty()) {
fromOffsets = checkupValidOffsets(consumer, lastCheckpointStr, topicPartitions); fromOffsets = checkupValidOffsets(consumer, lastCheckpointStr, topicPartitions);
} else { } else {
KafkaResetOffsetStrategies autoResetValue = KafkaResetOffsetStrategies KafkaResetOffsetStrategies autoResetValue = KafkaResetOffsetStrategies