У меня после ввода json:
[
{
"measurementDate": "1/1/2010",
"Id": "id1",
"value": "1234"
},
{
"measurementDate": "1/1/2010",
"Id": "id2",
"value": "12334"
}
]
Я сделал следующий поток:
tFileInput JSON -> tMap -> tlogRow Это вывод, который я получил? :
.---------+---------------------------------+-----------.
| tLogRow_1 |
|=--------+---------------------------------+----------=|
|timestamp|id |value|
|=--------+---------------------------------+----------=|
|1/1/2010 |id1|1234 |
|1/1/2010 |id2|12334 |
'---------+---------------------------------+-----------'
Теперь, как мне сделать каждую строку в виде массива json и отправить ее в Kafka ??
это формат сообщения kafka:
[{"id":"id1","timeStamp":"1/1/2010","value":"1234"}]