Nifi - отображение двоичного типа avro в Postgres? - PullRequest
Новая
       103

Nifi - отображение двоичного типа avro в Postgres?

0 голосов
/ 29 мая 2020

У меня есть следующее определение avro для моего потока Nifi, где я читаю из столбца базы данных BLOB. Я отображаю столбец xxPZPVSTREAM как тип байтов в моем определении avro 

{
    "namespace":"a.b.c",
    "name":"pc_history",
    "type":"record",
    "fields":   [
        {"name":"COMMITDATETIME","type":["null",{"type":"long","logicalType":"timestamp-millis"}]},
        ....
        {"name":"xxPZPVSTREAM","type":["bytes","null"]},
        {"name":"xxx","type":["string","null"]}
    ]
}

Когда я пытаюсь записать сопоставленные данные в базу данных Postgres, я получаю эту ошибку 

org.postgresql.util.PSQLException: Can’t infer the SQL type to use for an instance of [Ljava.lang.Byte;. Use setObject() woth an explicit Types values to specify the type to use.

Могу ли я добавить дополнительную метаинформацию в определение avro, чтобы процессор Nifi мог правильно сопоставить этот двоичный столбец?

...