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

Question

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

Answer 1

您可以尝试设置key.converter并org.apache.kafka.connect.storage.StringConverter保持value.converter设置为 Avro 之一。

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

J。