WSO2 SP - источник Кафки с атрибутами JSON - PullRequest
Новая
       24

WSO2 SP - источник Кафки с атрибутами JSON

4 голосов
/ 27 марта 2019

Я пытаюсь прочитать данные JSON из Kafka, используя следующий код: 

@source(type = 'kafka', bootstrap.servers = 'localhost:9092', topic.list = 'TestTopic', 
group.id = 'test', threading.option = 'single.thread', @map(type = 'json'))

define stream myDataStream (json object);

, но не получилось из-за следующей ошибки:

[2019-03-27_11-39-32_103] ОШИБКА {org.wso2.extension.siddhi.map.json.sourcemapper.JsonSourceMapper} - поток «myDataStream» не имеет атрибута с именем «ABC», но полученное событие {«event»: {«ABC»:"1"}} делает.Отсюда выбрасываю сообщение.Проверьте правильность формата строки json для сопоставления по умолчанию.

Я попытался добавить атрибуты 

@source(type = 'kafka', bootstrap.servers = 'localhost:9092', 
topic.list = 'TestTopic', group.id = 'test', 
threading.option = 'single.thread', 
@map(type = 'json', @attributes(ABC = '$.ABC')))

Синтаксическая ошибка:

Ошибка в 'json' определена в потоке 'myDataStream', атрибут 'json' не сопоставлен

Любая помощь будет принята с благодарностью.

1 Ответ

1 голос
/ 27 марта 2019

В синтаксисе потока есть ошибка, 

define stream myDataStream (ABC string);

Здесь имя атрибута является ключом сообщений JSON, в данном случае ABC

...