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

Question

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

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"}}}'

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

How to consume and produce messages with JSON schemas through the Kafka Console Consumer and Producer

json

apache-kafka

kafka-consumer-api

kafka-producer-api

confluent-schema-registry