@Override
    public void ack(String msgKey, String msgOffset)
            throws Exception {
        logger.debug("ack:{} offset:{}", msgKey, msgOffset);
        TopicFetcher topicFetcher = getFetcher(msgKey);
        topicFetcher.ack(msgOffset);
    }
ack offset to msgKey

@param msgKey String
@param msgOffset String
@throws Exception
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/SortClientImpl.java