Spring Boot中如何实现@KafkaListener批量并发接收Kafka消息的详细代码示例？

本文共计1105个文字，预计阅读时间需要5分钟。

Kafka是我项目开发中常用的消息中间件。由于其优秀的写入性能，经常会遇到读取消息队列时拥堵的情况。在这种情况下，我们有时无法直接清理整个topic。

kakfa是我们在项目开发中经常使用的消息中间件。由于它的写性能非常高，因此，经常会碰到读取Kafka消息队列时拥堵的情况。遇到这种情况时，有时我们不能直接清理整个topic，因为还有别的服务正在使用该topic。因此只能额外启动一个相同名称的consumer-group来加快消息消费（如果该topic只有一个分区，再启动一个新的消费者，没有作用）。

完整的代码在这里，欢迎加星号、fork。