Kafka添加了ACL权限后,Storm该如何消费?

酋长_lee 发布于 2017/09/04 14:02
阅读 206
收藏 0

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

加载中
0
天天爬网
天天爬网

解决了吗,登记一下

0
johnchou
johnchou

kafka数据为什么要用storm去消费

返回顶部
顶部