从演员订阅话题

Question

您如何使用akka演员订阅kafka话题？

从我所了解的卡夫卡消费者将与卡夫卡的套接字连接。当一个消息进入订阅的主题，然后kafka会发回一个信号并“唤醒”消费者，它将从主题中拉出。这在理论上是它的工作方式？

Answer 1

编号消费者客户不会收到关于写入的通知。

卡夫卡有一个纯粹的拉式消费模式。消费者客户需要主动poll()卡夫卡经纪人来检查新消息。这通常在循环中完成，直到您终止您的客户端。