我有一个Kafka集群(运行在K8S中,汇合平台,Helm)。我想要一个能够克服1代理失败的设置。我尝试过多种设置,但总的来说,这对我来说是一个相当新的话题。
基本上,我有一个生产者应用程序和多个事件侦听器。我不想确保一个代理的失败不会使整个集群崩溃。
以下是我到目前为止尝试过的:
。
什么是最优的解决方案--消息的数量并不大。我想使经纪人的数量合理地低,以生产设置。有什么好的办法吗?
在工作集群中,我指的是能够检索消息并将消息传递给使用者的集群。
发布于 2021-08-03 01:55:33
3代理,复制因子3,同步复制:2
应该足以处理一个代理下降的场景。
如果主题定义是用所需的配置定义的,如果不更改定义,请再次检查它。
检查使用相同配置定义的内部偏移主题。
共享3个经纪人的日志,同时让一个代理被关闭。
共享主题定义--描述,这样我们就可以确保它的定义正确。
https://stackoverflow.com/questions/68624250
复制相似问题