@@ -2208,6 +2208,10 @@ spec:
22082208 description : Query for custom SQL query (optional, if not
22092209 provided, reads from table)
22102210 type : string
2211+ rawMode :
2212+ description : ' RawMode when true, wraps each row as JSON: {"value":
2213+ <row data>, "_metadata": {table, id}}'
2214+ type : boolean
22112215 table :
22122216 description : Table to read from
22132217 type : string
@@ -2310,6 +2314,11 @@ spec:
23102314 description : ' Format specifies the message format: "json"
23112315 (default) or "avro"'
23122316 type : string
2317+ rawMode :
2318+ description : ' RawMode when true, wraps each message as JSON:
2319+ {"value": <message value>, "_metadata": {offset, partition,
2320+ timestamp, key, topic}}'
2321+ type : boolean
23132322 sasl :
23142323 description : SASL configuration
23152324 properties :
@@ -2643,6 +2652,10 @@ spec:
26432652 description : Query for custom SQL query (optional, if not
26442653 provided, reads from table)
26452654 type : string
2655+ rawMode :
2656+ description : ' RawMode when true, wraps each row as JSON: {"value":
2657+ <row data>, "_metadata": {table, id}}'
2658+ type : boolean
26462659 table :
26472660 description : Table to read from
26482661 type : string
@@ -2862,6 +2875,10 @@ spec:
28622875 description : Query for custom SQL query (optional, if not
28632876 provided, reads from table)
28642877 type : string
2878+ rawMode :
2879+ description : ' RawMode when true, wraps each row as JSON: {"value":
2880+ <row data>, "_metadata": {catalog, schema, table}}'
2881+ type : boolean
28652882 schema :
28662883 description : Schema to use
28672884 type : string
0 commit comments