Использую Spring, Kafka, Schema Registry, Avro, у меня такой вопросы: 1)

Question

Использую Spring, Kafka, Schema Registry, Avro, у меня такой вопросы: 1)

у меня есть 2-два микросервиса и есть "schem-ы avro", эта схема используется как контракт между двумя микросервисами,
чтоб отправленную строку можно было Serialize, Deserialize в pojo object.

Однако как мне сделать эту schema "shared", для двух микросервисов? я ведь не буду копипейстить файлик этот для каждого микросервиса.

2) У нас есть Schema Registry, куда добавляются мои schema, но добавляется только после первой отправки сообщения через kafka,
мне кажется что все схемы которые существуют в проекте - уже должны быть добавлены в kafka, а не после первой отправки!

Потому что если schema которую мы отправляем через kafka будет неправильной, то есть вероятность что все приложения поломаются,
consumer-ы не смогут с таким работать, поэтому все схемы уже должны быть в kafka, как это можно сделать?

#kafka #russian #software

0

06.04.2020

1 ответов

12 просмотров

Морозов Иван · Accepted Answer

Морозов Иван

Вам нужно класть схему в реджистри при создании топика. Для этого можно воспользоваться либо рест интерфейсом реджистри, либо джавовой либой-оберткой

0

06.04.2020

52 похожих чатов

Использую Spring, Kafka, Schema Registry, Avro, у меня такой вопросы: 1)

1 ответов

Похожие вопросы