從演員訂閱話題

Question

您如何使用akka演員訂閱kafka話題？

從我所瞭解的卡夫卡消費者將與卡夫卡的套接字連接。當一個消息進入訂閱的主題，然後kafka會發回一個信號並「喚醒」消費者，它將從主題中拉出。這在理論上是它的工作方式？

Answer 1

編號消費者客戶不會收到關於寫入的通知。

卡夫卡有一個純粹的拉式消費模式。消費者客戶需要主動poll()卡夫卡經紀人來檢查新消息。這通常在循環中完成，直到您終止您的客戶端。