此功能:
https://kafka.apache.org/10/documentation/streams/developer-guide/config-streams.html#acks
KubeMQ流中似乎缺少。我们是遗漏了什么,还是他们遗漏了?这将从根本上改变我们在选择事件驱动模型时的架构决策。或者,也许我们错过了一种新的方式/术语,即使用事件和KubeMQ的持久性来保证一次交付?
提前感谢
使用KubeMQ 的事件和持久性保证一次交付
根据文件,这不可能(目前?(
支持最多一次交付和至少一次交付
https://docs.kubemq.io/
如果你想在Kubernetes中运行一个Kafka代理,你可以看看Strimzi操作符,作为一个例子。