【发布时间】：2018-11-22 02:38:12
【问题描述】：
我正在寻找一个 debezium mysql 连接器，以将 CDC 记录流式传输到 kafka，其中键为 string（不是 avro 键），值作为 avro 记录。默认情况下，它将密钥作为 avro 记录。有什么建议吗？
【问题讨论】：
【发布时间】：2018-11-22 02:38:12
【问题描述】：
您可以尝试将key.converter 设置为org.apache.kafka.connect.storage.StringConverter 和value.converter 保持设置为Avro 之一。
或者您可以使用 JSON 转换器，因为它也可以序列化为文本。
J.
【讨论】：
-
您可以在Debezium documentation 中找到有关 Avro 配置的更多详细信息。正如 Jiri 所说，只需为密钥指定其他转换器之一。
-
这确实是一个很好的建议，因为密钥将是一个字符串，但来自 Debezium 的 MS SQL Server 连接器的架构注册表使用仍处于测试阶段，并且在其上使用 AVRO 转换器将停止重写 DELETE今天。