Re: Allow keys to specify partitionKey

2019-10-21 Thread Boyang Chen
Hey Jan, correct me if I'm wrong, my understanding of your problem is as follows: 1. This is a Kafka Streams question 2. You want to preserve the same primary key, but to repartition based on some certain field with key/value If this is the case, have you considered using `through(topic,

Allow keys to specify partitionKey

2019-10-21 Thread Jan Bols
The default partitioner takes a hash of the key of a topic to determine the partition number. It would be useful for a key to be able to specify the object on which the default partitioner should base its hash on. This would allow us to use different composite keys and still be certain that