public Queue<T> getRecords() {
            return records;
        }
used to check whether starting position and current message we got actually are equal
we neglect the potential batchIdx deliberately while seeking to MessageIdImpl for batch entry.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/ReaderThread.java