@Override
    protected String getThreadName() {
        return "kafka-source-" + taskId + "-" + instanceId;
    }
kafka source, split kafka source job into multi readers
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/KafkaSource.java