Kafka并行度配置

在Spring Kafka中， spring.kafka.listener.concurrency 是一个配置属性，用于设置Kafka消息监听器容器的并发消费者数量。它指定了每个主题分区的并发消费者线程数量。
具体来说，可以通过以下方式配置 spring.kafka.listener.concurrency 属性：

1. 在Spring Boot应用程序的 application.properties 或 application.yml 文件中添加以下配置：
   
   这将配置Kafka消息监听器容器的并发消费者数量为4个线程。
2. 在Spring配置类中使用 @ConfigurationProperties 注解，创建一个配置类来设置该属性：
   
   在上述配置中， concurrency 属性可以通过 application.properties 或 application.yml 文件中的 spring.kafka.listener.concurrency 进行设置。
   请注意，此配置属性适用于使用Spring Kafka的消息监听器容器（ ConcurrentKafkaListenerContainerFactory ）来处理Kafka消息的情况。它指定了每个主题分区的并发消费者线程数，以实现更高的并发处理能力。具体的并发级别需要根据实际需求和系统资源进行调整和优化。