9.3.3.3. Debezium デフォルトトピック作成グループ設定の指定

前提条件

• Kafka Connect のカスタムリソースで、metadata.annotations の use-connector-resources の値により、クラスターの Operator が KafkaConnector カスタムリソースを使用してクラスター内のコネクターを設定するように指定されている。以下に例を示します。

   ...
      metadata:
        name: my-connect-cluster
        annotations: strimzi.io/use-connector-resources: "true"
   ...

手順

• topic.creation.default グループのプロパティーを定義するには、以下の例に示すように、コネクターのカスタムリソースの spec.config にプロパティーを追加します。

  apiVersion: kafka.strimzi.io/v1beta1
  kind: KafkaConnector
  metadata:
    name: inventory-connector
    labels:
      strimzi.io/cluster: my-connect-cluster
  spec:
  ...
  
     config:
  ...
       topic.creation.default.replication.factor: 3  1
       topic.creation.default.partitions: 10  2
       topic.creation.default.cleanup.policy: compact  3
       topic.creation.default.compression.type: lz4  4
  ...

  任意の Kafka トピックレベルの設定プロパティー を default グループの設定に含めることができます。