Re: Samza partition hashing relative to other clients

2022-12-14 Thread Stuart Perks
Hi Malcolm, You should be able to override the following producer config for partitioner.class: https://kafka.apache.org/24/documentation.html#producerconfigs This can be done as follows via Samza config systems.system-name.prod

Samza partition hashing relative to other clients

2022-12-14 Thread Malcolm McFarland
Hey folks, I'm working on a system where several different Kafka clients (including Samza) are producing into the same Kafka topic. It's necessary for each of these clients to calculate the same partition hash for the same key input to ensure consistent message ordering (there are some asynchronou

[ANNOUNCE] Welcome Ajo Thomas as Samza Committer

2022-12-14 Thread Xinyu Liu
Hi, All, I am glad to announce that Ajo Thomas has officially accepted our invitation and become an Apache Samza Committer now. Ajo has made contributions to improve both Samza user experience and operability greatly. He added the partial update functionality to Samza Table API to allow field-lev