NanerLee/storm-kafka-test

Storm-Kafka-Test

本代码是使用 storm-kafka-client 消费和生产 kafka 数据的示例, 包括非安全模式和使用 kerberos 认证的安全模式

环境

• jdk-1.7 及以上
• storm-1.0.6
• kafka-0.10.0.0

详解

具体详解参考我的这边文章 Storm 访问使用 Kerberos 认证的 Kafka 集群

参考

• 官方文档: Storm Kafka Integration
• storm-kafka-kerberos