All Questions
133 questions
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 ...
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
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
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
139
views
2 versions of amazon-kinesis-client library in one project
I have a project that use the "software.amazon.kinesis:amazon-kinesis-client:2.5.0" library for quite some time for consuming events from kinesis stream.
Recently we started using "org....
-1
votes
1
answer
536
views
Naming Convention for using source in StreamBridge SPRING CLOUD STREAM
im using streamBridge in 2 different locations like this:
streamBridge.send("first", "hello1");
streamBridge.send("second", "hello2");
now the problem is that ...
- 57
0
votes
1
answer
463
views
How to correctly configure errorChannel in spring cloud (spring integration)?
I have a webapp in which I use Kinesis Stream with spring-cloud-stream, spring-cloud-stream-binder-kinesis and spring-cloud-starter-sleuth. What I would like to do is to configure the error handling ...
- 683
0
votes
1
answer
146
views
Functional binding is disabled due to the presense of @EnableBinding annotation in your configuration
I upgraded spring boot to 2.3.0.RELEASE and the spring boot application is stuck at the last line and it never starts. Any help is appreciated, Thanks!
09:26 23:57:52.276 [main ] [WARN] [...
- 343
0
votes
1
answer
354
views
How to make spring cloud connect to an existing RabbitMQ Exchange and queue
So I have a spring boot appplication and I am using spring cloud to connect to my RabbitMQ server.I read the documentation but some things are still vague to me .For now my application creates the ...
- 43
0
votes
1
answer
1k
views
Spring Cloud Stream Consumer not consuming messages
Below is the code of Consumer Service which consumes from kafka topic loc-4. The producer service is producing the messages, I can see in the console, but not able to log the messages and do any ...
- 47
0
votes
1
answer
28
views
Is it possible to inject a value from the named channel configuration property in spring-cloud-stream?
I have a spring-cloud-stream-kafka project. The following is an abbreviated section of application.yaml. I am interested in injecting the value for the property spring.cloud.stream.kafka.bindings....
- 2,160
0
votes
1
answer
229
views
Forward ApplicationEvent to RabbitMQ using funtions
My application should spread some event from a component to some rabbit message publisher.
My component fires the event using ApplicationEventPublisher.publishEvent(e)
On the other side, a message ...
- 1,157