Skip to main content

All Questions

Filter by
Sorted by
Tagged with
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 ...
LuxusIo's user avatar
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 ...
maxoverhere's user avatar
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 ...
Stev's user avatar
  • 307
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 ...
codependent's user avatar
  • 24.6k