private String getOffset(int partitionId, long offset) {
            return partitionId + ":" + offset;
        }
put the received msg to onFinished method

@param messageRecords {@link List < MessageRecord >}
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/kafka/KafkaSingleTopicFetcher.java