我目前正在学习Scala并试图创建一个SimpleConsumer来检索来自Kafka分区的消息 .
消费者应该能够处理以下任务:
-
跟踪偏移量 .
-
找出哪个Broker是主题和分区的主要代理
-
必须能够处理经纪人领导者的变化 .
我能够找到一个非常好的文档来用Java创建这个使用者(https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example) .
有没有人有一个示例Scala代码来创建这个简单的消费者,或者如果你可以参考我一些文件,这将指出我正确的方向,将非常感谢 .
2 回答
以下是使用Scala编写的Simple Kafka使用者的示例代码 . 经过一些试验和错误后,它得到了工作 .
我使用scala构建了一个简单的kafka使用者和 生产环境 者 .
消费者:
制片人: