我正在写一个测试，在Assert某些事情之前，我需要等到主题中有2条记录。i、 然后想得到这两条记录并对它们进行Assert。我似乎找不到一种方法来查找一个主题中的记录数而不实际地使用它们。
下面是我想做的一个简短的介绍。我正在听一个发表在主题“x”上的活动。在消费了这个事件之后，我在同一主题“x”中发布了一个新的事件“”。现在我想基于已发布的事件“”来做一些Assert。在测试中，我有一个单独的消费者订阅了“x”。所以我应该等到我知道有两个事件供消费者消费时再Assert
我正在写一个测试，在Assert某些事情之前，我需要等到主题中有2条记录。i、 然后想得到这两条记录并对它们进行Assert。我似乎找不到一种方法来查找一个主题中的记录数而不实际地使用它们。
下面是我想做的一个简短的介绍。我正在听一个发表在主题“x”上的活动。在消费了这个事件之后，我在同一主题“x”中发布了一个新的事件“”。现在我想基于已发布的事件“”来做一些Assert。在测试中，我有一个单独的消费者订阅了“x”。所以我应该等到我知道有两个事件供消费者消费时再Assert
1条答案
按热度按时间ljo96ir51#
消息本身不会被消费。它们只发送给每个订阅的消费群一次，但仍保留在主题中供将来使用。因此，您可以使用专门的消费者组来“消费”它们，并在不担心其他消费者的情况下执行测试。