Ошибка ключа Кафки при доступе к topi c в presto - PullRequest
0 голосов
/ 23 февраля 2020

Я пытаюсь структурировать JSON данные из топики Кафки c в таблицу Presto с запросом. Я получаю эту ошибку, говоря,

com.facebook.presto.spi.PrestoException: end offset 8 for column 'kafka_key' must be less that or equal to value length 0

в файле журнала сервера. Если для скрытого поля в описании указано значение true, сервер Presto запускается, но после установки значения false для него значение не устанавливается.

Почему не сопоставляется внутренний ключ kafka? Почему смещение 8, а не 0?

Спасибо.

...