我正在尝试使用以下代码从kafka读取json数据：

@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”没有名为“”的属性，但接收的事件{“event”：{“”：“1”}有。因此删除消息。检查json字符串的默认Map格式是否正确。
我试过添加属性

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

语法错误：
流“mydatastream”中定义的“json”处出错，未Map属性“json”
任何帮助都将不胜感激。