EmbeddedConsumer 构造函数中 blackListTopics 取值错误

[ykgarfield]

public EmbeddedConsumer(ConsumerConfig consumerConfig, ProducerConfig producerConfig, ServerStartable serverStartable) {
        this.consumerConfig = consumerConfig;
        this.serverStartable = serverStartable;
        //
        this.whiteListTopics = Arrays.asList(consumerConfig.getMirrorTopicsWhitelist().split(","));
        this.blackListTopics = Arrays.asList(consumerConfig.getMirrorTopicsWhitelist().split(","));
        this.producer = new Producer<Void, Message>(producerConfig);
    }

blackListTopics 取值错了，应该是 consumerConfig.getMirrorTopicsBlackList()。

[adyliu]

谢谢。确实是个错误。

[adyliu]

df986c5