我有Spring-boot Kafka pub sub microserivces,如图所示。我想为我的每个应用程序做集成测试。
UseCase1: UseCase1, consumes
Topic X
,process,produces
to Topic Y
。
UseCase2: 只是从Topic X
中消费并处理它
在我的测试中,我想要发布一条消息到Topic X
(用于Springboot--c),该消息应该由处理并生成到Topic Y
,我想确认该特定消息是否生成到主题Y。
的缺点:当我向主题X生成一条消息时,Springboot-app-c
和Springboot-app-c, springboot-app-b and spring-boot-app-d
都会选择它。当我尝试测试一个应用程序时,它在不知不觉中测试了三个应用程序,我想要对它进行更多的控制。我希望测试消息仅由spring-boot-app-c
拾取。如何使其特定于应用程序并分别测试每个应用程序
发布于 2019-06-20 03:31:40
如何知道某件事已发布到主题Y
向topic Y的测试中添加一个使用者,以验证您收到了预期的数据。
如何在特定应用的测试消息中只有一个来自主题X的正确消费者
不能;Kafka中没有用于条件路由或消息选择的机制。所有消费者组都会收到一份该消息的副本。
你必须使用不同的主题。
https://stackoverflow.com/questions/56672033
复制相似问题