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

【问题标题】：How to consume and produce messages with JSON schemas through the Kafka Console Consumer and Producer如何通过 Kafka 控制台消费者和生产者使用 JSON 模式消费和生产消息
【发布时间】：2020-08-13 14:00:55
【问题描述】：

是否可以在 Kafka 中使用 kafka-console-consumer 和 kafka-console-producer 分别使用和生成带有 JSON 模式的消息？

【问题讨论】：

标签： json apache-kafka kafka-consumer-api kafka-producer-api confluent-schema-registry

【解决方案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"}}}'

【讨论】：