spring-boot-cloud-streams相关内容

num.stream.threads 创建空闲线程

我有一个带有 2 个主题的 Spring Boot kafka 流应用程序,考虑主题 A 和 B.主题 A 有 16 个分区,主题 B 有 1 个分区.考虑将应用程序部署在具有 num.stream.threads=16.我运行 kafka-consumer-groups.bat 命令来检查线程如何分配给组中的分区,得到以下输出.主题 A 和 B 分配了 16 个线程,其中主题 B 中的 14 个 ..

num.stream.threads创建空闲线程

我有一个带有两个主题的spring boot kafka流应用程序,考虑主题A和B.主题A有16个分区,主题B有1个分区.考虑将应用程序部署在1个实例中,该实例的num.stream.threads = 16. 我运行kafka-consumer-groups.bat命令来检查如何将线程分配给组中的分区,得到以下输出.主题A和B分配了16个线程,其中主题B中的14个线程处于空闲状态. kaf ..