'Spring cloud stream Functional Programming
I was trying to consume a Kafka Message and publish two message to different Topic .
spring.cloud.stream.bindings.slotNotification-in-0:
destination: customer
spring.cloud.stream.bindings.slotNotification-out-0:
destination: processer
spring.cloud.stream.bindings.slotNotification-out-1:
destination: status
JAVA Code
@Bean
public Function<SlotNotification, String[]> slotNotification() {
return slotNotification -> {
String[] outArray = {"PROCESS","STATUS"};
return outArray;
};
}
Dependency:
'org.springframework.boot' version '2.4.5'
implementation 'org.springframework.cloud:spring-cloud-stream-binder-kafka'
I am seeing that data is going to out-0 but not in out-1 Is there anything wrong I am doing here . Please help .
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
| Solution | Source |
|---|
