Flatten CDC records in KSQL