アクターからトピックを購読する

Question

akkaアクターを使用してカフカトピックを購読する方法を教えてください。

私はカフカ消費者がカフカとソケット接続を行うことを理解しています。購読されたトピックにメッセージが来ると、kafkaはシグナルを送り返して消費者を「起きる」ことになり、トピックから引き出します。これは理論的にはそれが働く方法ですか？

Answer 1

いいえ。コンシューマクライアントは書き込みについて通知されません。

カフカには純粋なプルベースの消費者モデルがあります。消費者クライアントは、新しいメッセージを確認するために活発にpoll()カフカのブローカーが必要です。これは通常、クライアントを終了するまでループで実行されます。