Hello, I am writing a kafka sink connector for my product that is distributed table (Underneath a distribute K-V store where cluster of nodes are holding a different partitions/buckets of a table. This is based on Hash partitioned on Keys).
When i write a SinkTask, I get the SinkRecord that contains both key and value. Can some one suggest/outline the general guidelines for keys to be used with K-V store from the SinkRecord. What should be the key for external K-V store to be used to store a records from kafka topics to external K-V store. Thanks, Nilkanth.
