I have a case where i want to publish message from Kafka Producer, My message is just a POJO object e.g CreateRequest. So for consuming I have added below code Also,I have added setMessageConverter and setPayloadType to get response of type CreateResponse but still i am getting response of type KafkaMessageSource which is throwing java.lang.ClassCastException cannot cast KafkaMessageSource to type
Tag: spring-integration-dsl
How to add transaction support to Java DSL integration flows
I have to add a transaction support to an integration flow. Let’s assume that there are 3 transformers. The first and third transformers should be done within the same transaction, but the second one shouldn’t be done within any transaction. Thus, if an error occurs in the third transformer, all changes from the first and third transformers should not be
Break the Transformer flow Spring Integration
I have spring integration flows. One for the file poller and other one is to process the file flow # 01 poll the file in C:/testing directory files comes goes to “process” queue flow # 02 (from “process”) The issue is if the FindTheDepartItBelongs cannot find the department then it has to stop the rest of the flow and send