製作卡夫卡製作人和消費者同步

Question

我有一個卡夫卡製作人和消費者。卡夫卡製作人正在發佈到一個主題，數據被拍攝並完成了一些處理。卡夫卡消費者正在閱讀關於是否成功處理來自主題1的數據的另一主題，即主題2具有成功或失敗消息。現在Iam開始我的消費者，然後將數據發佈到主題1。我​​想讓製片人和消費者同步，即一旦生產者發佈數據，消費者應該讀取該數據的成功或失敗消息，然後生產者應該繼續下一組數據。

Answer 1

Apache Kafka和Publish/Subscribe消息一般旨在通過使用流異步事件來分離生產者和消費者。您所描述的更像是批處理作業或同步遠程過程調用（RPC），其中生產者和消費者明確地耦合在一起。標準的Apache Kafka生產者/消費者API不支持這種消息交換模式，但是您可以在使用關聯ID，消費確認和請求/響應消息的Kafka API之上始終編寫自己的簡單包裝來製作自己的界面如你所願。