public void mergeOffset()

in src/main/java/com/aliyun/odps/kafka/connect/SinkStatusContext.java [58:64]

• 6 lines of code
• 3 McCabe index (conditional complexity)

  public void mergeOffset() {
    // 针对offset的区间更新consumedOffset
    while (!offsetIntervalSet.isEmpty() && consumedOffsets + 1 == offsetIntervalSet.firstKey()) {
      consumedOffsets = offsetIntervalSet.firstEntry().getValue();
      removeFirst();
    }
  }