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