分布式消息服务KAFKA版-升级Kafka实例内核版本:升级内核版本的影响

时间:2024-07-26 17:29:58

升级内核版本的影响

  • 若Topic为单副本,升级期间无法对该Topic生产消息或消费消息,会造成业务中断。
  • 若Topic为多副本,升级不会造成服务中断,但可能会导致消费的分区消息发生乱序,请谨慎评估业务影响,建议您在业务低峰期升级。
  • 升级过程中节点滚动重启造成分区Leader切换,会发生秒级连接闪断,在用户网络环境稳定的前提下,Leader切换时长一般为1分钟以内。多副本的Topic需要在生产客户端配置重试机制,方法如下:
    • 生产客户端为Kafka开源客户端时,检查是否配置retries参数,建议此参数值设置为3~5。
    • 生产客户端为Flink客户端时,检查是否配置重启策略,配置重启策略可以参考如下代码。
      StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
      env.setRestartStrategy(RestartStrategies.fixedDelayRestart(3, Time.seconds(20)));
support.huaweicloud.com/usermanual-kafka/kafka-ug-0070.html