大家好,现在我的Spring Boot 应用程序运行在aws eb docker平台,我想设置不同的Kafka消费者组ID时,创建一个新的示例由aws自动缩放(水平缩放).是可能的吗?例如:例如示例1Kafka消费者组ID = my-consumer-group-1,示例2的Kafka消费者组ID = my-consumer-group-2,
因为我需要为Kafka创建不同的消费者组ID
我想了很多办法都找不到
大家好,现在我的Spring Boot 应用程序运行在aws eb docker平台,我想设置不同的Kafka消费者组ID时,创建一个新的示例由aws自动缩放(水平缩放).是可能的吗?例如:例如示例1Kafka消费者组ID = my-consumer-group-1,示例2的Kafka消费者组ID = my-consumer-group-2,
因为我需要为Kafka创建不同的消费者组ID
我想了很多办法都找不到
1条答案
按热度按时间2g32fytz1#
一般来说,一个应用的扩展应该是同一个组。然后它将并行读取相同的主题。同样,使用这种方法,你不应该基于CPU或内存自动扩展,例如,因为Kafka消费者只能扩展到主题分区的数量。你应该基于消费者滞后进行扩展(这是你需要从应用中公开的自定义指标)。
如果您不关心并行消耗,那么您可以使用随机UUID,而不需要任何特定于Beanstalk变量的东西。