kafka 是否可以从 0.11.0.1 升级到运行中的更新版本



我们正在运行 apache kafka 0.11.0.1 集群。我们计划在不停止服务的情况下升级到 0.11.0.2。

是否可以在不丢失数据或重现的情况下进行升级?

我们的卡夫卡集群状态:

    多个经纪人,多个
  • 生产者,多个消费者。
  • 每个主题都传播到多个分区
  • 每个主题至少有 2 个副本,并且所有副本都是同步的。

我们认为升级步骤:

  1. 停止一个 0.11.0.1 代理。
  2. 在停止的节点上启动 0.11.0.2。(相同的服务器属性(
  3. 对所有经纪人执行 1 和 2

基本上,消费者是由kafka客户端0.11.0.1和Spark DStream消费者组成的。

当然,我们将测试。但你知道,测试不能保证一切都会好起来的。任何信息都必须有帮助。请给我建议。

是的,Kafka 可以在不停机的情况下升级。

在 Kafka 文档中有相当大一部分关于升级的内容: http://kafka.apache.org/documentation/#upgrade

对于类似方案(0.11.0.0 到 0.11.0.1(的次要版本升级,您描述的步骤应该可以正常工作。逐个升级每个代理,并在每个步骤之后等待所有内容恢复同步。

最新更新