Debezium 连接器将 kafka 密钥作为 avro 插入？

Question

我正在寻找一个 debezium mysql 连接器，将 CDC 记录流式传输到 kafka，键为 string （不是 avro 键），值作为 avro 记录。默认情况下，它会将密钥作为 avro 记录。有什么建议吗？

Answer 1

您可以尝试将

key.converter

设置为

org.apache.kafka.connect.storage.StringConverter

并且

value.converter

保持设置为 Avro

或者您可以使用 JSON 转换器，因为它也可以序列化为文本。