Receiving Messages
-
配置 MessageListenerContainer 并提供消息侦听器:这种方法涉及配置一个 MessageListenerContainer,并提供一个实现 MessageListener 接口的 Java 类作为侦听器。当收到消息时,该侦听器将被调用。
-
使用 @KafkaListener 注释:这种方法更简单,它涉及在 Java 方法上添加 @KafkaListener 注释。当收到消息时,将调用该方法。
你可以通过配置 MessageListenerContainer
并提供消息侦听器或使用 @KafkaListener
注释来接收消息。