I’m trying to create a stream with a composite key following the answer from @rmoff in apache kafka connect - How to create KSQL table from a topic with composite key? - Stack Overflow, however, like another recent commenter, I’m running into “
MY_COMPOSITE_KEY must be a column in the source schema since PARTITION BY is applied on the input.”
Any suggestions? I can duplicate all the details here if it will help.
As further background, the whole reason I’m trying to do this to deal with the issue that we can’t join on more than one column, as described here by @vxia : KSQLDB: JOINs on multiple conditions are not yet supported · Issue #8574 · confluentinc/ksql · GitHub
Any help is much appreciated?