Multi Binder with based on business logic

[voodemsanthosh]

Hi Team,

I am trying to find best solution on Spring steam with functions. My requirement like below,

We will get request data in a topic(X) and have to respond to two different topics(Y and Z) based on my business logic.

I implemented below code snippet for general process on same topic,

Processer.java

@Bean
public Function<request, response> process() {
 // here i just process my request and return response
}

Configuration:

spring: cloud: stream: function: definition: process bindings: process-in-0: destination: X contentType: application/json group: x-input kafka: binder: brokers: localhost:9092

But now requirement got changed like below.

1. incase of my request data contains error, I need to publish response to topic Y
2. incase of my request data processed successfully, I need to publish my response to topic Y and request data to topic Z.

Both topics are available on same brokers.

Please suggest and guide me with good documents and example to design this.