Dears,
I am trying to insert JSON messages from JSON schema defined topic into a table called jsoncheck. Below is the pipeline syntax I am using
CREATE OR REPLACE PIPELINE pl_b2b_json_schema
AS LOAD DATA KAFKA ‘10.XX.XX.XX:9092/jsoncheck’
BATCH_INTERVAL 2500
DISABLE OFFSETS METADATA GC
INTO TABLE json_check
(json_check
.paylaod
← %)
FORMAT JSON;
Table syntax: create table json_check(paylaod JSON);
I am getting below error:
Leaf Error (scdglbtb58.gyy.kjl.gh:3307): JSON syntax error at byte 0 of object 0. Error: The document is empty. Contents just before that byte: .
and I don’t want to skip parser error as correctly formed JSON will also be skipped.
Please help me resolve this issue
Thanks