网站编辑电子商务网站运营专员,甜点网站开发需求分析,免费建站网站一级大录像不卡在线看网页,制作学校网站客户端如果订阅了多次主题#xff0c;则以最后一次为主#xff0c;例如 consumer.subscribe(Arrays.asList(topic1)); consumer.subscribe(Arrays.asList(topic2)); 则订阅的只有topic2。 消费者订阅主题是支持正则表达式#xff0c;这样如果有新topic上线#xff0c;并且匹…客户端如果订阅了多次主题则以最后一次为主例如 consumer.subscribe(Arrays.asList(topic1)); consumer.subscribe(Arrays.asList(topic2)); 则订阅的只有topic2。 消费者订阅主题是支持正则表达式这样如果有新topic上线并且匹配正则则也会消费到这个新topic的内容比如 consumer.subscribe(Pattern.compile(topic-.*)); 消费者也可以订阅某些主题的具体分区 consumer.assign(Arrays.asList(new TopicPartition(topic-demo,0))); 取消订阅也就是不订阅 consumer.subscribe(new ArrayList()); consumer.assign(new ArrayList());
