1 package de.example.spring.kafka;
3 import org.springframework.cloud.stream.messaging.Source;
4 import org.springframework.context.annotation.Bean;
5 import org.springframework.context.annotation.Configuration;
8 public class SenderConfig {
11 public Sender sender(Source source) {
12 return new Sender(source);