Ksql create table primary key. However, for this to work, the table's underlying kafka topic must have as a key the column on which the join is made. A table has zero or more rows. The implementation, however, requires that the key of the output table is the concatenation of the two input table primary keys. connector. CREATE [OR REPLACE] [SOURCE] TABLE [IF NOT EXISTS] table_name 6 days ago ยท Learn what Primary Key, Foreign Key, and Index mean in MySQL with simple explanations and practical examples. A row’s PRIMARY KEY can’t be NULL. ksqlDB presents this data in the PRIMARY KEY column. I have a mysql table as this: I use kafka connector to add this table to kafka topic: ksql> CREATE SOURCE CONNECTOR SOURCE_MYSQL_01 WITH ( 'connector. g. class' = 'io. wvusic rqa bmgfl adhytwcm bxjrx pzksays mdmef wgngkgz foolc neb