All Questions
4 questions
0
votes
1
answer
682
views
Manual ack after message send with Spring Cloud Stream + RabbitMQ (Functional)
I found how to do manual ack with functional way.
However, this does not explain how to do manual ack sending after messages.
If there is a networking error between the ack and the sending of the ...
0
votes
0
answers
601
views
Module was compiled with an incompatible version of Kotlin error after upgrading spring_cloud.version to 2021.0.0
I am attempting to update the spring cloud dependency from spring_cloud.version=2020.0.3
to spring_cloud.version=2021.0.0.
This causes an error when running the gradle build due to the following error
...
0
votes
1
answer
613
views
Use Function to replyTo RPC request
I would like to use the java.util.Function approach to reply to an request send via RabbitTemplate.convertSendAndReceive. It's working fine with the RabbitListener but I can not get it working with ...
1
vote
1
answer
1k
views
Spring Cloud Stream generates unnecessary complex Kafka topologies, why?
I have a KStream application with a bunch of KStreams, joins and other operations. I enabled logging.level.org.springframework.kafka.config=debug to verify the Topology that was being generated and ...