我们最近一直致力于将我们的 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 图表,但无法找到任何似乎相关的属性。