Как получить пользовательский LogicalType в Connect - PullRequest
0 голосов
/ 05 июля 2019

Я хочу иметь несколько строковых полей с максимальным размером значения. Структура данных описывается и проверяется с помощью схемы Avro.

Поскольку в Avro (1.8.2) такого типа нет - размер FIXED действительно фиксированный, и я бы предпочел избежать ненужного раздувания данных (т. Е. Заполнить некоторые пробельные символы, чтобы получить размер значения полей). ) - Я пытался реализовать свой собственный LogicalType в соответствии с Как определить LogicalType в Avro. (Java) Это хорошо работает для контекста API Kafka (2.2) Producer, НО:

Как я могу ввести свой собственный LogicalType (с проверкой значения поля) в контексте API Kafka Connect? Это вообще возможно?

...