您可以通过配置和提供消息侦听器或使用注释来接收消息。MessageListenerContainer@KafkaListener