Как отправить каждую строку в виде json массива кафки сообщений в talend - PullRequest
0 голосов
/ 11 февраля 2020

У меня после ввода 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"}]
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...