2
回答
Kafka添加了ACL权限后,Storm该如何消费?
【腾讯云】校园拼团福利,1核2G服务器10元/月!>>>   

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
发帖于8个月前 2回/114阅
顶部