启用集成的 Kafka 定制操作处理器 (KCOP)

集成的 Kafka 定制操作处理器 (KCOP) 与 CDC Replication Engine for Kafka一起运行 "开箱即用"。只需在 Management Console 中的用户出口上下文菜单中引用处理器，即可选择这些处理器。

关于本任务

可以使用 KCOP 来控制 Kafka 生产者记录，这些记录会写入 Kafka 主题，以响应源数据库表上执行的插入、更新和删除操作。 CDC Replication Engine for Kafka 为多个用例提供集成的 KCOP ，包括以 JSON 编写主题，指定用户定义的主题名称以及编写审计记录。有关更多信息，请参阅针对 Kafka 的 CDC Replication Engine 的 Kafka 定制操作处理器 (KCOP)。

过程

在管理控制台中，单击配置 > 预订。
选择订阅。
右键单击预订并选择 Kafka 属性。
验证是否选择了 ZooKeeper 作为 Kafka 应用的方法。
单击“确定”。
右键单击预订并选择用户出口。
根据所需的集成 Kafka 定制操作处理器，输入类名和参数的值:

KcopLiveAuditSingleRowIntegrated

以逗号分隔值 (CSV) 格式写入审计记录。

KcopJsonFormatIntegrated

以 JSON 格式写入记录。

KcopDefaultBehaviorIntegrated

连接到兼容 Confluent 的模式注册表并写入 Kafka。

KcopTopicMappingIntegrated

支持指定主题名称并设置多个源表与目标主题之间的映射。

KcopMultiRowAvroLiveAuditIntegrated

以 Avro 格式写入审计记录，并在 Confluent 模式注册表中或在 Hortonworks 模式注册表服务中注册模式。

KcopSingleRowAvroAuditIntegrated

将 Avro 格式的审计记录与前映像记录和后映像记录写入同一行。

KcopJsonSingleRowAuditFormatIntegrated

将 JSON 格式的审计记录与前映像和后映像一起写入一行。
单击“确定”。