Как получать и создавать сообщения со схемами JSON через Kafka Console Consumer and Producer - PullRequest
Новая
       58

Как получать и создавать сообщения со схемами JSON через Kafka Console Consumer and Producer

1 голос
/ 29 апреля 2020

Можно ли использовать и генерировать сообщения со схемами JSON в Кафке, используя kafka-console-consumer и kafka-console-producer соответственно?

1 Ответ

1 голос
/ 29 апреля 2020

Confluent Platform 5.5 добавляет поддержку JSON Схема , которая также поставляется с 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"}}}'
...