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