カフカでプロデューサーに通知するには？

Question

私はkafkaでメッセージを送信し、消費者がビジネスルールを処理するプロデューサーを持っていますが、消費者がメッセージの処理を終了したらプロデューサーに通知する必要があります。プロデューサーに通知するために終了したら、消費者は別のトピックに関するメッセージを送信する必要がありますか、それを行う他の方法はありますか？

この画像が正しいかどうかを確認してください。カフカのデザインのアイデアは完全にデカップル生産者と消費者になるため

kafka flow

Answer 1

は、カフカには、ビルドのメカニズムはありません。

トピックをバックチャネルとして使用すると効果があります。もちろん、他にも多くの解決策があります。

Answer 2

消費者がすべてのメッセージの処理を終了したと判断できる場合は、コンシューマをシャットダウンして数秒待つだけです。
Zookeeperクライアントを使用してコンシューマZNodeを監視すると、クライアントが通知を受け取り、プロデューサに転送することができます。ただし、スレッド間の通信が必要な場合があります。
それが正しいかどうか分かりませんが、試してみるといいと思います。