@KafkaListene有哪些参数
时间: 2024-01-12 11:04:12 浏览: 82
kafka笔记参数说明
@KafkaListener 是 Kafka 中用于标注方法是一个消息监听器的注解,常用的参数包括:
1. id:监听器的唯一标识符,当存在多个监听器时,需要指定不同的 id。
2. topics:监听的主题名称,可以设置一个或多个主题。
3. topicPartitions:监听的主题分区信息,可以设置一个或多个主题分区信息。
4. containerFactory:指定使用的 KafkaListenerContainerFactory 实例,用于创建 KafkaListenerContainer。
5. errorHandler:指定用于处理监听器异常的实例。
6. groupId:指定消费者组的 ID。
7. concurrency:指定消费者线程池的并发数。
8. autoStartup:指定监听器是否自动启动。
9. clientIdPrefix:指定消费者的客户端 ID 前缀。
10. beanRef:指定 Kafka 监听器容器的 bean 引用,用于从 Spring 容器中获取 KafkaListenerContainer。
11. splitIterables:指定是否将消息拆分为单独的记录进行处理。
12. properties:指定 Kafka 客户端属性。
13. errorHandlerClass:指定用于处理监听器异常的类。
14. setupTopics:指定在启动监听器之前自动创建的主题列表。
15. topicPattern:指定主题名称的正则表达式,用于动态匹配主题名称。
这些参数可以根据实际需求进行设置,用于控制 Kafka 监听器的行为。需要注意的是,并不是所有参数都需要设置,可以根据实际需求进行选择性设置。
阅读全文