To introduce to my problem, first I will show how I could solve this on a relacional database:
But first: I know I just can join things (on KSQLDB) by its PRIMARY KEYS. And that’s my point.
SELECT * FROM ORDERS O INNER JOIN PROVIDER P ON O.PROV = P.PROVIDER_COD AND O.SUB_COD = P.SUB_COD;
Now let me explain:
I’m getting those data from MS SQL SERVER CDC drive. And according to this database design there’s no primary key any where. So, if I want to join those two tables I have to use two codes, the
provider code and
provider sub code .
I’ve done a lot, but I can’t figure out how to solve this. I’m almost thinking KSQLD can’t deal with data like this.
One thing I think would work out is setting a composite key on Kafka topic key, but I do not know how to do that.
Could, please, someone help me?