9.3.3.4. Debezium カスタムトピック作成グループ設定の指定

手順

• カスタムトピックグループを定義するには、コネクターのカスタムリソースの spec.config に topic.creation.<group_name>.include プロパティーを追加し、続いてカスタムグループのトピックに適用する設定プロパティーを定義します。

  次の例では、カスタムトピック作成グループ inventory と applicationlogs を定義するカスタムリソースの抜粋を示しています。

  apiVersion: kafka.strimzi.io/v1beta1
  kind: KafkaConnector
  metadata:
    name: inventory-connector
  ...
  spec:
  ...
  
     config:
  ... 

  1

  
      topic.creation.inventory.include: dbserver1\\.inventory\\.*  

  2

  
      topic.creation.inventory.partitions: 20
      topic.creation.inventory.cleanup.policy: compact
      topic.creation.inventory.delete.retention.ms: 7776000000
  
      

  3

  
      topic.creation.applicationlogs.include: dbserver1\\.logs\\.applog-.* 

  4

  
      topic.creation.applicationlogs.exclude": dbserver1\\.logs\\.applog-old-.*  

  5

  
      topic.creation.applicationlogs.replication.factor: 1
      topic.creation.applicationlogs.partitions: 20
      topic.creation.applicationlogs.cleanup.policy: delete
      topic.creation.applicationlogs.retention.ms: 7776000000
      topic.creation.applicationlogs.compression.type: lz4
  ...
  ...

  Copy to Clipboard Toggle word wrap