使用 Debezium 而不是 Avro 输出 JSON 消息

Question

是否可以使用 Debezium 而不是 Avro 生成 JSON 消息？我有一个 Debezium Kafka Connect 适配器，我正在尝试让它将 JSON 消息输出到 Kafka 主题中。

这可能吗？

Answer 1

您应该能够添加这些以获得 JSON 输出

key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter

Output JSON messages with Debezium rather than Avro