如何通知kafka的制片人？

Posted 2021-04-26

我有一个生产者在kafka上发送消息，消费者处理业务规则，但我的生产者需要在消费者完成处理消息时得到通知。消费者在完成时是否需要在另一个主题上发送消息以通知生产者，还是有其他方法可以做到这一点？

看看这张图片是否正确。

kafka flow

答案

Kafka没有内置机制，因为Kafka设计的想法是完全解耦生产者和消费者。

使用主题作为反向渠道应该有效。当然，还有许多其他可能的解决方案。

另一答案

如果您可以确定消费者完成处理所有消息，只需关闭消费者并等待几秒钟。 使用Zookeeper客户端观察消费者ZNode，当它被删除时，客户端获得通知并可以将其传输给producer。但是您可能需要在线程之间进行通信。 我不知道是不是，但我认为你可以尝试一下。