Open voodemsanthosh opened 3 years ago
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.
Both topics are available on same brokers.
Please suggest and guide me with good documents and example to design this.
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
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.
Both topics are available on same brokers.
Please suggest and guide me with good documents and example to design this.