All Questions
Tagged with spring-cloud spring-cloud-stream
451 questions
0
votes
0
answers
40
views
Is it possible to ignore unknown properties in payload in Spring Cloud Stream Kafka?
Is there a way to be able to ignore unknown properties of a payload and still deserialize it to the target class when using Spring Cloud Stream binder?
import org.springframework.messaging.Message;
......
2
votes
0
answers
87
views
How to configure retryable exceptions for consumers when Kafka transactions are enabled?
We are trying to configure retryable exceptions together with Kafka transactions and dead letter queues, on Spring Cloud Stream. That is, we want to specify which exceptions should be retried.
It ...
- 20.7k
2
votes
0
answers
210
views
Spring Boot 3.4.0: ConverterNotFoundException for SpEL property spring.cloud.stream.rabbit.default.producer.routing-key-expression
After upgrading my application from Spring Boot 3.3.X to 3.4.0 (Spring Cloud 2024.0.0) I get the following Exception at startup:
Failed to bind properties under 'spring.cloud.stream.rabbit.default....
- 53
0
votes
0
answers
24
views
Spring Cloud Stream: Can a single consumer bean consume messages from different message broker clusters?
I use Spring Cloud Stream v4.
Here is my application.yml code:
spring:
cloud:
stream:
kafka:
binder:
configuration:
key.serializer: org.apache.kafka.common....
- 1,104
0
votes
0
answers
23
views
How to know if a MessageChannel is inbound or outbound channel in spring cloud stream 4.x version onwards?
Prior to 4.x version, based on this issue https://github.com/spring-cloud/spring-cloud-stream/issues/1425, we could check if a message channel instance is DirectWithAttributesChannel and then use Sink....
- 150
1
vote
0
answers
145
views
Lack of registered modules in Jackson objectmapper after Spring boot upgrade
Trying to upgrade my app, dependencies to be changed:
spring-cloud from 2023.0.0 -> 2023.0.3
Spring boot from 3.2.5 -> 3.3.2
Noticed issues with de/serialization, it looks like inheritance was ...
1
vote
0
answers
93
views
Spring Cloud Stream for SB3 tracing headers are Base64 encoded, makes it incompatible with SB2
When using micrometer with Spring Boot 3 and Sleuth with Spring Boot 2, we can make these two versions compatible for tracing. We can set to use b3 and w3c format together. It works fine, but there is ...
- 528
0
votes
1
answer
201
views
Substitute for @EnableBinding and @StreamListener in Kafka 3.6.2
I've been working on a migration from Spring 2.X to 3.X and my old code used @EnableBinding(Sink::class) and @StreamListener(Sink.INPUT) in the consumer. With both being deprecated and removed from ...
0
votes
1
answer
134
views
Spring Cloud Binder function - acknowledge and throw error
I am wondering how the spring cloud views/would view the requirement of consuming from a cloud binder as a function, transforming that object by getting some data from an api (or something similar) ...
0
votes
1
answer
112
views
Spring cloud stream multi cluster connection: AdminClient and Consumer throw error: Failed to create consumer binding
Problem: when I try to configure multi cluster connection for spring cloud stream kafka my application throw an error for each topic: Failed to create consumer binding retrying in 30 seconds org....
- 191
0
votes
1
answer
73
views
Custom DefaultErrorHandler not getting called in multiple bindings kafka
I have a spring cloud kafka binding consumer service. Where the main consumer topic and the dlq consumer are in different brokers. Thus I need to create multiple bindings.
The issue what I am facing ...
- 3,809
0
votes
2
answers
473
views
Spring Cloud Stream Multiple Kafka Clusters Configuration
In my project, I need to connect to two different Kafka brokers.
My application.yaml looks somewhat like this:
spring:
cloud:
function:
definition: orderCreatedListener;...
0
votes
1
answer
46
views
Producing message for RabbitMq using Supplier
I need to poll messages and publish them to RabbitMQ. There are 100 stores set up, and each store can poll more than 5 messages and publish them to RabbitMQ. Polling occurs every minute. Below is the ...
- 81
0
votes
0
answers
42
views
Spring cloud functional style and integration-test
I have a Spring Boot 3.1.6 project using Spring Cloud 2022.04 and Spring Cloud Stream 4.0.4.
It is setup so the integration-test consumes events produced by the application to verify them.
Like so:
...
0
votes
1
answer
86
views
Is it possible for Spring Cloud Stream to use both old @EnableBinding-@StreamListener and new functional style in one project?
Below is the code with both types of kafka consumers which I try to use .
@SpringBootApplication
@EnableBinding(MixApplication.IncomingBinding.class)
@Slf4j
public class MixApplication {
public ...
