Kafka增加了SASL认证，消费端也要做相应的调整。阿里官方jstorm中的jstorm-kafka，使用SimpleConsumer去消费数据，我研究了好久，不知道怎么增加认证。 于是只好新写了个SaslPartionConsumer，封装了org.apache.kafka.clients.consumer.KafkaConsumer去消费带有SASL认证的Kafka。
参考代码中的KafkaSpoutTest.java类
-
Notifications
You must be signed in to change notification settings - Fork 0
pirate4444/jstorm-kafka
About
实现jstorm的KafkaSpout，在官方代码的基础上，实现sasl认证的kafka的消费。
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published