I am trying to integrate Spring Cloud Stream Schema Registry with MongoDB as the Schema Registry backend. I just want to know with the current implementation will this be feasible and what kinds of changes will be required to achieve…
I have a simple Spring Cloud Azure Service Bus consumer defined as simply as follows, following the official documentation: @Bean public Consumer<Message<byte[]>> consume() { return message -> someProcessing(message); } The default policy, if the spring.cloud.stream.servicebus.bindings.consume-in-0.consumer.requeue-rejected flag is false, is that…
I am using Spring Cloud Stream with Azure Service Bus. These are my relevant versions and dependencies: <spring-cloud-azure.version>4.3.0</spring-cloud-azure.version> <spring-cloud.version>2021.0.3</spring-cloud.version> <dependency> <groupId>com.azure.spring</groupId> <artifactId>spring-cloud-azure-starter</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-stream</artifactId> </dependency> <dependency> <groupId>com.azure.spring</groupId> <artifactId>spring-cloud-azure-stream-binder-servicebus</artifactId> <version>4.3.0</version> </dependency> I want to implement retry policy, where message…