Spring for Apache Kafka 参考 使用 Spring for Apache Kafka 接收消息 接收消息 您可以通过配置 MessageListenerContainer 并提供消息监听器来接收消息,也可以使用 @KafkaListener 注解。 章节摘要 消息监听器 消息监听器容器 手动提交偏移量 异步 @KafkaListener 返回类型 @KafkaListener 注解 获取消费者 group.id 容器线程命名 将 @KafkaListener 用作元注解 类上的 @KafkaListener @KafkaListener 属性修改 @KafkaListener 生命周期管理 @KafkaListener @Payload 验证 重新平衡监听器 强制消费者重新平衡 使用 @SendTo 转发监听器结果 过滤消息 重试投递 按顺序启动 @KafkaListeners 使用 KafkaTemplate 接收 发送消息 消息监听器