@Override
    public boolean accept(String mqType) {
        return MQType.KAFKA.equals(mqType);
    }
The name rule for Kafka consumer group: clusterTag_topicName_consumer_group
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/kafka/KafkaQueueResourceOperator.java