我有两个Kafka主题：topic_a和topic_B，其中数据已经被注入。
对于应用程序的第一次部署，我需要在使用topic_b的消息之前使用topic_a的消息。
实际上，在接收到关于topic_B的消息时触发的计算假设我们已经接收到关于topic_a的数据。
这就是为什么我想阻止topic_b上的消费，直到topic_a上的消费完成。
用最少的步骤实现这一目标的最佳方法是什么？
我有两个Kafka主题：topic_a和topic_B，其中数据已经被注入。
对于应用程序的第一次部署，我需要在使用topic_b的消息之前使用topic_a的消息。
实际上，在接收到关于topic_B的消息时触发的计算假设我们已经接收到关于topic_a的数据。
这就是为什么我想阻止topic_b上的消费，直到topic_a上的消费完成。
用最少的步骤实现这一目标的最佳方法是什么？
1条答案
按热度按时间ztyzrc3y1#
您可以检查“主题A”上的消费者滞后，但是如果有一个活动的生产者向该主题发送数据，则可能永远不会发生; Kafka没有定义“完全消费”，除了这个属性。换句话说，基于上面的逻辑，如果至少有一个来自topic_a的事件到达，您也会希望“停止topic_b消费”？
在topic_B上接收消息假设我们已经在topic_a上接收到数据
如果您需要关联该数据，则可以使用Kafka Streams API进行Kafka主题连接。