Роль Debezium

Это роль Ansible для установки Debezium, инструмента с открытым исходным кодом для захвата изменений данных (Change Data Capture), который передает изменения в базе данных в Kafka Connect.

Смотрите последние документы по 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: веб-серверы

  roles:
    - role: libre_ops.debezium