Debezium 连接器将 kafka 密钥作为 avro 插入？
Debezium connector inserting kafka key as avro?
我正在寻找一个 debezium mysql 连接器，以将 CDC 记录流式传输到 kafka，键为 string（键不是 avro），值为 avro 记录。默认情况下，它会将密钥制作为 avro 记录。有什么建议吗？
您可以尝试将 key.converter 设置为 org.apache.kafka.connect.storage.StringConverter 并 value.converter 保持设置为 Avro。
或者您可以使用 JSON 转换器，因为它也可以序列化为文本。
J.
我正在寻找一个 debezium mysql 连接器，以将 CDC 记录流式传输到 kafka，键为 string（键不是 avro），值为 avro 记录。默认情况下，它会将密钥制作为 avro 记录。有什么建议吗？
您可以尝试将 key.converter 设置为 org.apache.kafka.connect.storage.StringConverter 并 value.converter 保持设置为 Avro。
或者您可以使用 JSON 转换器，因为它也可以序列化为文本。
J.