如何测试(集成测试)springboot-kafka微服务

内容来源于 Stack Overflow,并遵循CC BY-SA 3.0许可协议进行翻译与使用

  • 回答 (1)
  • 关注 (0)
  • 查看 (54)

如图所示,我有Spring-boot Kafka pub sub microsivivces。我想为每个应用程序进行集成测试。

UseCase1: SpringBoot应用内-C ,其consumesTopic X并对其进行处理和producesTopic Y

UseCase2: SpringBoot-App-b只是消耗Topic X并处理它

预期: 在我的测试中,我想发布一条消息Topic X(用于Springboot-app-c),该消息应由Spring-Boot-App-C处理并生成,Topic Y并且我想确认是否为主题Y生成了该特定消息或不 。

缺点: 当我产生一个消息主题X其意在Springboot-app-c与一起Springboot-app-c, springboot-app-b and spring-boot-app-d被捡起来。当我试图测试一个应用程序 - 它在不知不觉中测试三个应用程序,我想要更多的控制。我希望测试消息只能被选中spring-boot-app-c。如何使其具体应用并分别测试每个应用程序

  • 如何知道某些内容已发布到主题Y.
  • 如何只为主题X中的一个和正确的消费者提供该特定应用程序的测试消息
提问于
用户回答回答于

如何知道某些内容已发布到主题Y.

将消费者添加到测试主题Y以验证您是否收到了预期数据。

如何只为主题X中的一个和正确的消费者提供该特定应用程序的测试消息

你不能; Kafka中没有用于条件路由或消息选择的机制。所有消费者组都会获得该消息的副本。

您必须使用单独的主题。

扫码关注云+社区

领取腾讯云代金券