1. Can a normal table (non-upsert) have primnary key => then only defining "primaryKeyColumns": ["event_id"] in schema should be fine ??? 2. For upsert table if we have composit primary key like - "primaryKeyColumns": ["event_id", "eventName"] . And kafka partition key is like event_id (made of only one primary key field). Should it be fine ?

1. Yes, it is ok to have pk defined. In fact pk can be used for other purposes like join. 2. Yes, it’s fine to have coarser grained partitions