小编Kar*_*eth的帖子

我目前正在学习Scala并试图创建一个SimpleConsumer来检索来自Kafka分区的消息.

消费者应该能够处理以下任务:

1. 跟踪偏移量.
2. 找出哪个Broker是主题和分区的主要代理
3. 必须能够处理经纪人领导者的变化.

我能够找到一个非常好的文档来用Java创建这个使用者(https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example).

有没有人有一个示例Scala代码来创建这个简单的消费者,或者如果你可以参考我一些文件,这将指出我正确的方向,将非常感谢.