Create a KSQL table with composite key from attributes in value (json)

ksqlDB
1

I have an existing topic with events having null key and json values

Example event:
{
“consumer”: “abc”,
“src_event_id”: “abc123”,
“sc_type”: “cip”,
“sc_ven”: “eq1”,
“sc_res”: “PASS”,
“other_attr”: “efgh”
}

I am looking to create a KSQL table with a composite key consisting of src_event_id, sc_type and sc_ven and expose all other attributes of the json as columns. The objective is to allow users to run pull queries from the table based on src_event_id, even though uniqueness of the record is defined by the composite key.

2

This topic was automatically closed after 30 days. New replies are no longer allowed.