jstorm 是否支持kafka-spout的动态增删？

[unclebob2013]

想实现不重启topology的情况下，通过重新加载配置，实现动态增删spout，读取不同的kafka-topic，请问目前版本的jstorm是否支持这样实现？

[tongh-qtl]

你不是用storm-kafka的么，这个一个spout只能订阅一个topic，处理其他topic需要重新提交toplogy，不知道你是怎么做的

[unclebob2013]

发现storm1.0.x版本中支持了topic wildcard功能,通过配置正则来匹配topic名实现自动添加url：

conf.put("kafka.topic.wildcard.match",true);
SpoutConfig spoutconfig = new SpoutConfig(hosts, GlobalConfig.TOPIC_PATTERNS, GlobalConfig.ZKROOT, GlobalConfig.SPOUT_ID);

目前jstorm支持这个功能么？

[vipsql]

kafka的consumer支持同时订阅多个Topic, 可在外部增加动态变量去控制订阅topic的数目