我有一个在Kube集群中的pod上运行的kafka stream应用程序。

试图找到一种方法让Kube根据kafka主题延迟来放大/缩小Pod。

有没有人愿意和别人分享一些细节？

请您参考如下方法:

为了根据延迟进行放大，您的应用应该能够发布指标(例如，使用千分尺)，使用仪表类型(Gauge https://micrometer.io/docs/concepts#_gauges)

然后，您将需要使用监视系统(例如，普罗米修斯)来收集指标

根据仪表/度量标准的值放大/缩小。

(检查此示例项目作为https://github.com/learnk8s/spring-boot-k8s-hpa示例)

注意:但是请以我的评论为允许的最大使用者数量> =主题分区数