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

Question

Kafka采用了SASL+ACL的权限验证后，Storm中的KafkaSpout该如何修改呢？
我查看了storm-kafka-1.0.1和storm-kafka-1.1.1的源码，KafkaConfig均是使用旧的消费模式，即传入zookeeper connect，而非bootstrap.servers。
我需要使用新的消费方式，并将验证验证的参数传入，如：
props.put("bootstrap.servers", "ct0:9092,ct1:9092,ct2:9092");
props.put("security.protocol", "SASL_PLAINTEXT");
props.put("sasl.mechanism", "PLAIN");
是否有大神知道该怎么搞？

Answer 1

解决了吗，登记一下