通过Bean而不是application.yml文件以编程方式配置Kafka绑定器配置

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Processor;

@Configuration
@EnableBinding(Processor.class)
public class KafkaBindingConfig {
    
    @Bean
    public Consumer<Message<String>> kafkaConsumer() {
        return message -> {
            // 处理接收到的消息
            System.out.println("Received message: " + message.getPayload());
        };
    }
    
    @Bean
    public Supplier<Message<String>> kafkaSupplier() {
        return () -> {
            // 生成消息
            String payload = "Hello, Kafka!";
            return MessageBuilder.withPayload(payload).build();
        };
    }
}