'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