Debeziumの役割

これは、データベースの変更をKafka Connectにストリーミングする変更データキャプチャのためのオープンソースツールであるDebeziumをインストールするためのAnsibleロールです。

最新のDebeziumのドキュメントはこちらで確認できます。

デフォルト

デフォルト設定の詳細はこちらで確認できます。デフォルトのコネクタはpostgresですが、バージョンとともに上書きすることができます:

debezium_connector_name: debezium-connector-postgres
debezium_version: "0.9.5.Final"

セットアップ

おそらくKafka Connectを使用し、protobufsまたはwal2jsonのプラグインを利用することになるでしょう。これらは追加のセットアップが必要で、ここには含まれていませんが、wal2jsonはこのロールを通じてインストールできます。Kafkaとの対話に関するデフォルト設定はConfluentの使用を前提としています:

kafka_user: cp-kafka
kafka_group: confluent
kafka_plugins_path: /usr/share/java
kafka_connect_service: confluent-kafka-connect

例のプレイブック

- name: Debeziumをインストール
  hosts: webservers

  roles:
    - role: libre_ops.debezium