KafkaListener

KafkaListener是一个注解，用于在Spring Boot中创建Kafka消费者。通过在消费方法上添加@KafkaListener注解，可以指定要监听的Kafka主题，以及消费方法的并发线程数。在创建Kafka消费者时，可以使用KafkaDefaultListenerErrorHandler类来处理异常情况。该类实现了KafkaListenerErrorHandler接口，并重写了handleError方法来处理异常情况。

此外，需要注意的是，新版的Kafka已将offset的存储从Zookeeper转移到了Kafka brokers，并使用内部位移主题__consumer_offsets进行存储。关于KafkaListener的并发消费线程数，可以通过@KafkaListener注解的concurrency属性进行配置。例如，设置concurrency=4时，Spring-Kafka会为该@KafkaListener创建4个线程进行并发消费。

综上所述，KafkaListener是用于在Spring Boot中创建Kafka消费者的注解，可以通过设置并发线程数来实现并发消费。同时，可以使用KafkaDefaultListenerErrorHandler类来处理消费过程中的异常情况。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* [@KafkaListener详解与使用](https://blog.csdn.net/h4241778/article/details/122416366)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
- *2* *3* [Kafka](https://blog.csdn.net/weixin_45126339/article/details/123684108)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]