第 2 章 在 RHEL 上安装 Debezium 连接器
通过 AMQ Streams 安装 Debezium 连接器，方法是扩展 Kafka Connect with connector 插件。在部署了 AMQ Streams 后，您可以通过 Kafka Connect 将 Debezium 部署为连接器配置。
2.1. Kafka 主题创建建议
Debezium 将数据存储在多个 Apache Kafka 主题中。管理员前必须预先创建主题，或者您可以配置 Kafka Connect 以 自动配置主题。
以下列表描述了创建主题时需要考虑的限制和建议：
- Debezium Db2、MySQL、Oracle 和 SQL Server 连接器的数据库历史记录主题
对于前面的每个连接器都需要数据库历史记录。无论您手动创建数据库历史记录主题，使用 Kafka 代理自动创建主题，或者使用 Kafka Connect 创建主题，确保使用以下设置配置了主题：
- 无限或非常长的保留。
- 在生产环境中至少 3 个复制因子。
- 单个分区.
- 其他主题
当您启用 Kafka 日志压缩 以便保存给定记录 的最后 更改事件时，在 Apache Kafka 中设置以下主题属性：
-
min.compaction.lag.ms 为确保主题消费者有足够的时间接收所有事件和删除标记，请为前面的属性指定值，该属性大于您期望接收器连接器的最大停机时间。例如，考虑在将更新应用到接收器连接器时可能会出现的停机时间。
-
- 在生产中复制.
单个分区.
您可以放宽单一分区规则，但应用程序必须在数据库中处理不同行的超出顺序事件。一行的事件仍按顺序排序。如果您使用多个分区，则 Kafka 通过对密钥进行哈希来确定分区。其他分区策略需要使用单一消息转换(SMT)为每条记录设置分区号。
