public static boolean isNonStoppingOffset(BinlogOffset binlogOffset) {
        return BinlogOffsetKind.NON_STOPPING.equals(binlogOffset.getOffsetKind());
    }
Initialize the binlog offset according to the kind of binlog offset, so that the debezium
reader could interpret it and seek the reader to the offset.

<p>This method will be used in binlog reading phase, when the {@link StatefulTaskContext} is
being initialized to load the actual effective binlog offset.

<p>The binlog offset kind will be overridden to {@link BinlogOffsetKind#SPECIFIC} after the
initialization, as the initialized effective offset describes a specific position in binlog.

<p>Initialization strategy:

<ul>
  <li>EARLIEST: binlog filename = "", position = 0
  <li>TIMESTAMP: set to earliest, as the current implementation is reading from the earliest
      offset and drop events earlier than the specified timestamp.
  <li>LATEST: fetch the current binlog by JDBC
</ul>
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/offset/BinlogOffsetUtils.java