Obtenir le schéma enregistré par ID/sujet avec le connecteur

Est-il possible d'obtenir le schéma enregistré avec dans un connecteur source? J'ai un schéma statique enregistré dans le registre de schéma et j'ai besoin d'obtenir ce schéma du connecteur et de le passer à SourceRecord.Obtenir le schéma enregistré par ID/sujet avec le connecteur

J'ai utilisé CachedSchemaRegistryClient pour obtenir le schéma en utilisant l'ID de schéma, mais il a renvoyé un schéma Avro. Donc je dois convertir ceci en org.apache.kafka.connect.data.Schema. S'il vous plaît fournir quelques indications à ce sujet.

Ou tout autre moyen dans le connecteur où je peux faire la même chose directement avec CachedSchemaRegistryClient?

Merci, Sreejith

Source

2016-09-21 Sreejith.S

Vous pourriez faire un appel de repos au registre de schéma pour faire la recherche. Cependant, il s'agit d'une utilisation assez non standard d'un connecteur. Vous feriez mieux de faire ce genre de recherche dans un convertisseur.

Source

2016-10-01 17:14:43 dawsaw

Merci @dawsaw. Je suis capable de faire cela et j'obtiendrai un schéma Avro. Non, je dois convertir cela en Connect Schema et le transmettre dans SourceRecord. Cherchant maintenant un moyen de le faire. –

Obtenir le schéma enregistré par ID/sujet avec le connecteur

Répondre

Questions connexes