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 KafkaMessageSo…
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 c…
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…