Debezium角色

这是一个用于安装 Debezium 的Ansible角色，它是一个开源的变更数据捕获工具，将数据库变更流式传输到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: webservers

  roles:
    - role: libre_ops.debezium