我有基于Spring Cloud Stream构建的微服务。测试团队需要为这些服务创建集成测试。什么是最佳实践？根据下面的示例，不同应用程序的Sink/Source/Processor需要在测试项目的类路径中。期望是打包每个服务并将其包含在测试项目中吗？https://github.com/spring-cloud/spring-c
浏览 23提问于2019-04-18得票数 0
回答已采纳
在我们的项目中，我们使用spring-cloud-starter-stream-kafka来消费来自卡夫卡的消息，在添加了@ComponentScan for "org.springframework.cloud.stream.binder.kafka"包之后，集成测试开始失败，只有以下异常java.lang.IllegalStateException: Failed to loa
浏览 27提问于2022-05-18得票数 1
回答已采纳
2回答
使用云流测试不起作用
、、、、
我用spring-cloud-stream尝试了一些东西。一切正常，现在我试着写一些测试用例。不幸的是，它们不起作用。: stream: bindings: destination//Thread.sleep(1000);
assertEquals(massage, receiver.getLastMes
浏览 2提问于2017-07-07得票数 0
现在，我正在尝试添加一些集成测试，断言生产者实际上正在按照预期生成一条消息。问题是，我在测试中使用的使用者从来不阅读主题中的任何内容。为了使这个问题重现，我从spring云流样本中重新研究了一个项目(spring-cloud-stream-samples/source-samples/dynamic-destination-source-kafka> message = MessageBuilder.withPayload(payload)
浏览 3提问于2020-02-02得票数 1
回答已采纳
我们在同一个应用程序中使用了具有多个处理程序的Spring cloud stream，我们正在尝试创建一个集成测试。: stream: output_source1:
destination: source1我们检查了这个文档(https://cloud.spring.io/spring-<em
浏览 24提问于2019-12-27得票数 1
我想为我的配置服务器编写单元/集成测试，所以我检查了链接。里面有一个用@SpringBootTest注释的类和一个用@BeforeClass注释的函数startConfigServer()。我还可以为配置服务器编写哪些其他单元测试用例和集成测试？我还使用了Spring Cloud Stream Kafka和Spring Cloud Bus，同时启用了Spring Security基本身份验
浏览 7提问于2018-07-09得票数 0
我们进行了集成测试，最终将多条消息发送到同一个目的地，但有许多不同的组。在rabbitMQ术语中，相同的交换具有不同的主题。spring.cloud.stream.bindings.userEdited-out-0.destination=user.exchange
spring.cloud.stream.rabbit.bindings.userEdited-out-0.producer.routing-key-expression='use
浏览 4提问于2022-05-12得票数 1
回答已采纳
我正在尝试将Spring Cloud Stream应用程序Chelsea.SR1迁移到Horsham。此项目没有绑定器，但使用spring消息传递和集成来集成自定义源和接收器。artifactId> <relativePath /> <properties>
<s
浏览 1提问于2019-12-13得票数 0
到目前为止，我一直在研究spring云模式注册表和confluent模式注册表。我可以看到一些区别，比如spring云模式注册表将模式保存在普通数据库中，默认情况下保存在h2中，而confluent模式注册表保存在kafka topic中。对于spring云模式注册表，这种方法有没有性能影响？据我所知，即使数据被保存在主题上，如果是合流的情况下，查询仍然会有延迟。但是会有很大的影响吗？我还可以看到，spring云模式注册中心提供了对confluent模式注册中心的支持，这是否意味着confluent模式注册中心更好？ 这些
浏览 26提问于2021-06-29得票数 0
我不知道如何用kafka做一个样本测试，我试着按照弹簧指南做，但不起作用。
有人能帮我吗？: Failed to instantiate [org.springframework.cloud.stream.test.binder.MessageCollector]: Factory method(Ljava/lang/String;Ljava/lang/Class;)Lorg/springframework/cloud/stream&#
浏览 20提问于2017-02-17得票数 1
我使用的是spring cloud stream kafka。message.max.bytes=20000000spring.cloud.stream.kafka.bindings然而，我想概括一下spring cloud kafka中的所有主题
浏览 6提问于2019-08-28得票数 4
1回答
春季云流运动形态
、、、
我尝试在我的应用程序集成弹簧云流运动，但我找不到所有的配置选项，在那里的手册。我见过这样的联系：
spring.cloud.stream.instanceCount=hostnamesecret key我在找这样的东西：spring.cl
浏览 3提问于2019-06-16得票数 0
;import org.springframework.cloud.stream.messaging.SinkEtestSmsConsumerApplication.class, args);}
@ToString private String message;应用属性：
spring.<em
浏览 17提问于2017-02-01得票数 4
回答已采纳
我使用： <dependency> <artifactId>spring-cloud-starter-stream-rabbit</artifactId> </dependenc
浏览 114提问于2019-12-27得票数 0
回答已采纳
我一直在尝试为KafkaStreamsProcessor编写单元测试。logic });} aplication.yml spring: stream: streams: brokers:StreamsBuilder streams
浏览 6提问于2020-10-09得票数 0
回答已采纳
1回答
使用Spring的现有队列
、、、、
问题是，我无法阻止Spring集成试图在RabbitMQ中声明队列，这将返回一个错误。下面是我的application.properties的相关部分：
spring.cloud.stream.bindings.input.group=********************.instana.testspring.cloud.stream.rabbit.bindings.input.consumer.bind-queue=false spri
浏览 0提问于2018-10-16得票数 1
回答已采纳
2回答
有关于如何测试Spring云流应用程序而不连接到具有spring云流测试支持的消息传递系统的文章。但是我真的想通过集成测试连接到RabbitMQ，而不能这样做。下面是测试类：@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT创建与代理的真正连接并从测试中发送消息需要什么？
浏览 2提问于2018-04-13得票数 0
回答已采纳
1回答
我使用Spring 2.2.9 Hoxton.SR7和Spring Hoxton.SR7。我正在使用Spring总线在一个码头群堆栈中向我的所有容器发送信号，并且当在生产中与运行的RabbitMQ集群一起部署时，所有的事情都能很好地工作！我正在通过spring-cloud-starter-bus-amqp Spring使用RabbitMQ实现。我们偶尔不需要公共汽车就进行测试。这里有一个弹簧引导标志：
spring.cloud.bus
浏览 3提问于2020-08-05得票数 0
我正在使用spring -cloud-stream:1.3.0开发spring启动应用程序。messages，spring-cloud-stream-binder-kafka:1.3.0.RELEASE.我使用spring集成dsl来拆分文件中的行，并使用beanio将行转换为json，要求将成功的spring: stream:
浏览 2提问于2017-10-19得票数 1
云服务器
ICP备案
对象存储
云直播
实时音视频
腾讯云开发者
