Home

Welcome to the ksqlDB wiki!

The documentation of ingesting JSON document into ksqlDB stream is over here instead of the main page.

With JSON, you can determine which key you want it ingest into ksqlDB stream. When you create the stream, you can define the JSON key. Special system is require if your JSON contains array or a struct.

Example of JSON struct
"chunk-header": {
"timestamp": 1688299607,
"engine-type": "avenger",
"engine-version": "0.0.3.1",
"node-id": "xxxxxx3b-be74-57f2-91cd-50609364yyyy"
},

Example of JSON array
"dns-message": { "id": 33018, "rcode": "noerror", "opcode": "query", "flags": ["qr", "rd", "ra"], "question": [ { "name": "www.akamai.com.", "rdclass": "IN", "rdtype": "A" } ],