如何将 strimzi 巡航控制默认主题复制因子更改为 3？答案

【问题标题】：How to change strimzi cruise control default topic replication factor to 3?如何将 strimzi 巡航控制默认主题复制因子更改为 3？
【发布时间】：2022-11-29 07:02:23
【问题描述】：

我需要将 Strimzi 巡航控制默认主题（modeltrainingsamples、partitionmetricsamples）复制因子增加到 3，在配置下尝试，但它不起作用。

apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
  name: my-cluster
spec:
  kafka:
    version: 3.3.1
    replicas: 3
    listeners:
    - name: plain
      port: 9092
      type: internal
      tls: false  
    - name: tls
      port: 9093
      type: internal
      tls: true
    config:
      offsets.topic.replication.factor: 3
      transaction.state.log.replication.factor: 3
      transaction.state.log.min.isr: 2
      default.replication.factor: 3
      min.insync.replicas: 2
      inter.broker.protocol.version: "3.3"
    storage:
      type: ephemeral
  zookeeper:
    replicas: 3
    storage:
      type: ephemeral
  entityOperator:
  topicOperator: {}
  userOperator: {}
  cruiseControl:
    config:
      cruise.control.modeltrainingsamples.topic: strimzi.cruisecontrol.modeltraingsamples   
      cruise.control.modeltraingsamples.topic.replication.factor: 3
      cruise.control.modeltrainingsamples.topic.min.insync.replicas: 2
      cruise.control.modeltrainingsamples.topic: strimzi.cruisecontrol.partitionmetricsamples
      cruise.control.partitionmetricsamples.topic.replication.factor: 3
      cruise.control.partitionmetricsamples.topic.min.insync.replicas: 2

您能否建议更改 strimzi 巡航控制主题的默认主题复制因子？

【问题讨论】：

标签： apache-kafka linkedin cruisecontrol strimzi

【解决方案1】：

要更改示例存储主题 [1]、partition.metric.sample.store.topic 和 broker.metric.sample.store.topic 的默认复制因子，请像这样配置 Kafka 资源的 Cruise Control 配置部分：

apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
  name: my-cluster
spec:
  ...
  cruiseControl:
    config: 
      sample.store.topic.replication.factor: 3

请注意，Kafka 资源的 cruiseControl.config 部分可以采用 Cruise Control wiki [2] 中列出的大部分配置。有关更多信息，请在此处查看 Strimzi 文档 [1]

[1] https://strimzi.io/docs/operators/latest/configuring.html#property-cruise-control-config-reference

[2] https://github.com/linkedin/cruise-control/wiki/Configurations#kafkasamplestore-configurations

【讨论】：