如何为运行在 Kubernetes 上的 Pulsar 配置功能状态存储

问题描述 投票:0回答:0

我们最近一直致力于将我们的 Pulsar 集群迁移到 Kubernetes 上运行。我们已经成功地转移了基本功能和我们的水槽,但是我们一直在为我们的功能而苦苦挣扎。 我们有两个函数,都使用状态值,但是当调用它们时,当它们尝试访问它们的状态时我们会收到以下错误:

2023-04-28T07:58:33,565+0000 [public/tracking/playStartFunction-0] ERROR function-playStartFunction - Failed to process multi-cam message
java.lang.IllegalStateException: State public/tracking/playStartFunction is not enabled.

我们当前的集群在 EC2 实例上运行,我们使用 Ansible 配置 Pulsar。在此设置中,我们定义以下值:

# the service url points to bookkeeper table service
stateStorageServiceUrl: bk://{{ bookie_url }}:4181

但是,我们似乎无法在我们的新 K8s 部署中找到与此等效的东西。

有没有人有在 K8s Pulsar 集群上运行有状态函数的经验可以提供帮助?

我们查看了官方 HELM 图表,但无法找到任何似乎相关的属性。

java kubernetes devops kubernetes-helm apache-pulsar
© www.soinside.com 2019 - 2024. All rights reserved.