Spring allows interception of messages for many of their products, like RestTemplate and SpringMVC. Is it possible to intercept Spring Cloud Stream messages? For both incoming and outgoing messages...

There are so few examples of different methods of error-handling in spring cloud streams, and the few that are provided partially via the documentation don't seem to work either. I have a test repo...

I am using Spring Cloud Stream and want to programmatically create and bind channels. My use case is that during application startup I receive the dynamic list of Kafka topics to subscribe to. How ...

I have implemented kafka stream application. Let's say one of the object's field which the stream is currently processing contains a number instead of a string value. Currently when there is an exc...

The usual way of implementing the outbox pattern is to store the message payload in an outbox table and have a separate process (the Message Relay) query for pending messages and publish them into ...

i need to test a message, which contains headers, so i need to use MessageBuilder, but I can not serialize. I tried adding the serialization settings on the producer props but it did not work. Ca...

After upgrading to Spring Boot 3 I've had to update the tracing/correlation configuration to switch from Spring Cloud Sleuth to the new Micrometer Tracing library. At this point I can see traceId/s...

i want to create a common project (using spring cloud stream) to route messages to different (consumer) projects dynamically according to message content. (rabbitmq as the message broker) does spr...

I'm deploying a springboot application with spring-cloud-stream and binder for AWS Kinesis. The application works fine when is deployed on aws elastic beanstalk if the beanstalk is configured with ...

I'm struggling with customization of my spring kafka streams application. I have been trying to configure handling uncaught (runtime exceptions) at my KStreams. Refering to documentation https://do...

I have a service, which receives different structured messages from different message queues. Having @StreamListener conditions we can choose at every message type how that message should be handle...

I see that following annotations are depreciated for Spring Cloud Stream @Input @Output @EnableBinding @StreamListener Please provide examples and links to documentation as how to do it in function...

I have a spring boot application which has two functionalities Http requests and kafka Messages handling. I want this application to run in mode which is enabled from application.yml i.e if the use...

I am trying to create the simplest as possible hello world with Spring Cloud + Kafka Streams + Spring Boot 2. I realize I miss basic concepts. Basically, I understand that: 1 - I need to define a...

I have a spring-cloud-stream application with kafka binding. I would like to send and receive a message from the same topic from within the same executable(jar). I have my channel definitions such ...

I am using Spring Cloud Streams with the Kafka Streams Binder, the functional style processor API and also multiple processors. It's really cool to configure a processing application with multiple ...

I am trying to understand how the new functional model of Spring Cloud Streams works and how the configuration actually works under the hood. One of the properties I am unable to figure out is spri...

I'm using Spring Cloud Stream with Kafka Streams. Let's say I have a processor which is a Function which converts a KStream of Strings to a KStream of CityProgrammes. It invokes an API to find the ...

Is it possible to log inbound messages from stream function? Is there some kind of interceptor that allows me to do that?

Is there any info as to how can I use the AWS MSK details in my Spring Cloud Stream application ? I believe we need to generate a keystore and truststore and then incorporate the same in our appli...

Background I have the following JSON (message from Kafka) { "markdownPercentage": 20, "currency": "SEK", "startDate": "2019-07-25" } I have the following (JSON schema generated) POJO (I c...

I am using Spring Cloud Stream 3.1.2 for KafkaStreams. The programming models are: Functional Programming Imperative Programming The latter one uses annotations as all the other annotations that ...

could you please advise , how can I stop sending to my 3rd kafka topic, when the control reaches the catch block, currently the message is sent to both error topic as well as the topic to which it ...

Since version 3.1 the major API for working with queues is deprecated. In the class comment it says: Deprecated as of 3.1 in favor of functional programming model I searched a lot in the web for ...

I am trying to do a simple POC with Kafka Streams. However I am getting exception while starting the application. I am using Spring-Kafka, Kafka-Streams 2.5.1 with Spring boot 2.3.5 Kafka stream co...