ConfluentBootApplication.java

package com.seroter.confluentboot;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.messaging.support.GenericMessage;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
 
@EnableBinding(Source.class)
@RestController
@SpringBootApplication
public class ConfluentBootApplication {
 
    public static void main(String[] args) {
      SpringApplication.run(ConfluentBootApplication.class, args);
    }
     
    @Autowired
    private Source source;
  
    @PostMapping("/messages")
    public String postMsg(@RequestBody String msg) {
     this.source.output().send(new GenericMessage<&gt;(msg));
     return "success";
    }
}