我们希望通过apacke kafka发送事务数据，因为我们有两个下游系统，在ui中显示成功消息之前，我们希望确保数据成功保存在两个下游系统中。
我们将数据推送到生产者，在消费者端读取数据，并将其保存在下游系统中。缺少的链接是如何知道数据是否成功地保存在下游系统中，以便我们可以在ui上显示成功消息。
我们有没有办法通过Kafka来实现它。我们刚刚开始使用kafka，不确定这个用例是否适合kafka。
我们希望通过apacke kafka发送事务数据，因为我们有两个下游系统，在ui中显示成功消息之前，我们希望确保数据成功保存在两个下游系统中。
我们将数据推送到生产者，在消费者端读取数据，并将其保存在下游系统中。缺少的链接是如何知道数据是否成功地保存在下游系统中，以便我们可以在ui上显示成功消息。
我们有没有办法通过Kafka来实现它。我们刚刚开始使用kafka，不确定这个用例是否适合kafka。
1条答案
按热度按时间8i9zcol21#
如果生产者了解消费者，它可以观察承诺的消费者补偿，以查看哪些记录被消费。生产者可以将这些偏移Map到它自己编写的消息。
关于如何做到这一点的更多细节（远远超出了一个问题的范围），只需浏览Kafka代码（它是开源的）。作为一个起点，研究
bin/kafka-consumer-groups.sh这是一个监测消费者补偿的工具。