c# - 从 Docker 运行的自动扩展 Kafka Consumer

Question

我有一个包含 10 个分区的主题。我在 dockerize 环境中运行我的消费者。我希望泊坞窗根据以下条件自动扩大/缩小消费者组中消费者的实例-

1. 当在主题上生成的消息数量高于每时间单位消耗/处理的消息数量时，按比例放大 1 个实例。

如果消费者组中的消费者数量为 10，则不应自动缩放，因为我有 10 个分区。

2. 当在主题上生成的消息数量少于每个时间单位消耗/处理的消息数量时，缩小 ny 1 个实例。

我正在使用 .net 编写我的生产者/消费者和本地 Kubernetes 以对应用程序进行 dcokerize。我的生产者和消费者都是基于 .net core 3.0 的原生 windows 服务

标签： c#dockerapache-kafka