Блог

У меня проблема с apache kafka и выходом коннектора. когда я пытаюсь создать поток из темы, я получаю некоторые ошибки.

данные в этой теме следующие ( без схемы, в формате json ):

 key:  {  "payload": {  "sourceName": "HotPump",  "jobName": "pollingHotPump"  } }  value:  {  "payload": {  "fields": {  "cw": [  4657,  0,  0,  0,  0,  0,  0,  0,  0,  0,  13108,  16637,  0,  0,  0  ]  },  "timestamp": 1638540457655,  "expires": null,  "connection-name": "Condensator"  } }   

запрос ksql для создания потока такой:

   CREATE STREAM s_devices  (   key structlt;payload structlt;sourceName stringgt;gt; ,  value structlt;payload structlt;fields structlt;cw arraygt;gt;gt;,  ts structlt;payload structlt;timestamp bigintgt;gt;   )  WITH (KAFKA_TOPIC='devices',  VALUE_FORMAT='JSON', KEY_FORMAT='JSON');   

Результатом работы клиента ksql является: «Не удалось подготовить инструкцию: Не удается разрешить неизвестный тип: МАССИВ».

Когда я пытаюсь создать поток только при key structlt;payload structlt;sourceName stringgt;gt; select key-gt;payload-gt;sourceName, value-gt;payload-gt;timestamp from s_devices; правильном выборе, и отображается значение;

когда я пытаюсь только с ts structlt;payload structlt;timestamp bigintgt;gt; таблицей, создается, но когда я пытаюсь выбрать значение равно null select value-gt;payload-gt;timestamp from s_devices;

в чем же ошибка?

Спасибо