@Override
    public void configure(InLongTopic inLongTopic) {
        seekTime = TimeUtil.parseStartTime(inLongTopic);
        topic = inLongTopic.getTopic();
        LOGGER.info("start to config kafka seeker, topic is {}, seek time is {}", topic, seekTime);
    }
Kafka seeker.
Only seek those topics and partitions assigned by server.
The whole process can be divided into three steps:
1. Find all topics and partitions of this consumer;
2. Calculate the offsets of the excepted seek time of each topic and partition respectively;
3. Reset these topics and partitions to the corresponding offset
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/kafka/KafkaSeeker.java