32.3.2 接收消息

当完成Apache Kafka的基础配置，任何的bean都可以标注为@KafkaListener，来创建一个监听器端点。如果没有定义KafkaListenerContainerFactory，一个默认的将会用定义在spring.kafka.listener.*里的键值自动配置。另外，如果定义了一个RecordMessageConverter bean，它会自动关联到默认的工厂。
下面的组件在someTopic主题上创建了一个监听器端点：
@Component
public class MyBean {
​
    @KafkaListener(topics = "someTopic")
    public void processMessage(String content) {
        // ...
    }
​
}
最近更新 3yr ago