@Override
    public void remove(final List<String> topics) {
        CompletableFuture.runAsync(() -> topics.parallelStream().forEach(TOPIC_CHANNEL_FACTORY::remove));
    }
add subscribe channel.
@param channel channel
@param mqttTopicSubscription mqtt subscription info
shenyu-protocol/shenyu-protocol-mqtt/src/main/java/org/apache/shenyu/protocol/mqtt/repositories/SubscribeRepository.java