apache-kafka 设置aws弹性benastalk动态环境

guykilcj  于 2022-11-01  发布在  Apache
关注(0)|答案(1)|浏览(104)

大家好,现在我的Spring Boot 应用程序运行在aws eb docker平台,我想设置不同的Kafka消费者组ID时,创建一个新的示例由aws自动缩放(水平缩放).是可能的吗?例如:例如示例1Kafka消费者组ID = my-consumer-group-1,示例2的Kafka消费者组ID = my-consumer-group-2,
因为我需要为Kafka创建不同的消费者组ID
我想了很多办法都找不到

2g32fytz

2g32fytz1#

一般来说,一个应用的扩展应该是同一个组。然后它将并行读取相同的主题。同样,使用这种方法,你不应该基于CPU或内存自动扩展,例如,因为Kafka消费者只能扩展到主题分区的数量。你应该基于消费者滞后进行扩展(这是你需要从应用中公开的自定义指标)。
如果您不关心并行消耗,那么您可以使用随机UUID,而不需要任何特定于Beanstalk变量的东西。

相关问题