Kafka添加了ACL权限后，Storm该如何消费？

Kafka采用了SASL+ACL的权限验证后，Storm中的KafkaSpout该如何修改呢？
我查看了storm-kafka-1.0.1和storm-kafka-1.1.1的源码，KafkaConfig均是使用旧的消费模式，即传入zookeeper connect，而非bootstrap.servers。
采用权限验证后的Kafka是需要使用新的消费方式，需要将验证验证的参数传入，如：

props.put("bootstrap.servers", "ct0:9092,ct1:9092,ct2:9092");
props.put("security.protocol", "SASL_PLAINTEXT");
props.put("sasl.mechanism", "PLAIN");

是否有大神知道该怎么搞？