CODEWITHSUNDEEP
spring-bootfunctional-programmingspring-kafkaspring-cloud-stream-binder-kafka
Sven Weisker
Sven Weisker

Reputation: 13

Spring Cloud Stream Kafka send message

How can i send a message with the new Spring Cloud Stream Kafka Functional Model?

The deprecated way looked like this.

public interface OutputTopic {

    @Output("output")
    MessageChannel output();
}

@Autowired
OutputTopic outputTopic;

public someMethod() {
    
    outputTopic.output().send(MessageBuilder.build());
}

But how can i send a message in the functional style?

application.yml

spring:
  cloud:
    function:
      definition: process
    stream:
      bindings:
        process-out-0:
          destination: output
          binder: kafka

@Configuration
public class Configuration {

    @Bean
    Supplier<Message<String>> process() {
        return () -> {
            return MessageBuilder.withPayload("foo")
                    .setHeader(KafkaHeaders.MESSAGE_KEY, "bar".getBytes()).build();
        };
    }

I would Autowire a MessageChannel but there is no MessageChannel-Bean for process, process-out-0, output or something like that. Or can i send a message with a Supplier-Bean? Could someone please give me an example? Thanks a lot!

Upvotes: 1

Views: 3120

Answers (1)

Gary Russell
Gary Russell

Reputation: 174554

You can either use the StreamBridge or the reactor API - see Sending arbitrary data to an output (e.g. Foreign event-driven sources)

Upvotes: 6

Related Questions