I am running a Spring Cloud Stream application, consuming messages from RabbitMq. I want to implement a behaviour where a given queue, having three consumers instances, delivers exactly one message to any of them, and wait for the next to be delivered until the current is acked (some sort of synchronization between all consumers). I think that this can be
Tag: spring-cloud-stream
How to use avro native decoder when using a PollableMessageSource input in spring cloud stream?
I’m using a PollableMessageSource input to read from a Kafka topic. Messages on that topic are in Avro. use-native-decoding was set to true when those messages were published. This is how I’m polling: pollableChannels is just an injected instance of this interface: After seeing that the TypeClassName is not being formed properly (it’s nested objects are set to null by
@StreamListener is not visible when outside main Application class of Spring Boot. What could be the reason?
This is Spring Cloud Stream application. As i mention in the title, the StreamListener annotation works when inside the SpringBootApplication main class, but not when it resides in a different class with @Component annotation. I believe it is some sort of StreamListener visibility issue. I am publishing messages from the RabbitMQ management interface. Below is the exception i get: ConsumerApplication.java
Deserialize JSON date format to ZonedDateTime using objectMapper
Background I have the following JSON (message from Kafka) I have the following (JSON schema generated) POJO (I cannot change the POJO as it is shared resource in the company) Our application is a Spring Boot application which reads the JSON message (1) from Kafka using Spring Cloud Stream and uses the POJO (2) and then does stuff with it.