如何通过Kafka控制台使用者和生产者使用JSON模式消费和产生消息

Question

是否可以在Kafka中分别使用kafka-console-consumer和kafka-console-producer来使用JSON模式消费和产生消息？

Answer 1

Confluent Platform 5.5添加了support for JSON Schema，它也随kafka-json-schema-console-consumer和kafka-json-schema-console-producer一起提供。

---

使用JSON模式消费消息

kafka-json-schema-console-consumer --topic myTopic --bootstrap-server localhost:9092

使用JSON模式生成消息

kafka-json-schema-console-producer \
    --broker-list localhost:9092 \
    --topic myTopic \
    --property value.schema='{"type":"object","properties":{"f1":{"type":"string"}}}'