假设我有一个kafka集群,其中有一个生产者和一个消费者,在它后面是一个api服务器。api允许客户端写入(put请求)。当客户端写入时,它会将数据流中的事件生成到kafka中。然后,有一个使用者监听该流,负责更新用于索引的外部数据库。这是制造那个事件的副作用。我的问题是:有没有办法让api只在上述事件的副作用发生后才做出响应?换句话说,在api级别,我是否可以等到某个消费者是最新的?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!