1
回答
Kafka添加了ACL权限后,Storm该如何消费?
利用AWS快速构建适用于生产的无服务器应用程序,免费试用12个月>>>   

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");
是否有大神知道该怎么搞?

举报
酋长_lee
发帖于3个月前 1回/61阅
顶部