Re: Re: questions of partition and task of Samza

Hi, Yan: Thanks a lot for your answer. Sincerely, Selina On Mon, Oct 26, 2015 at 8:03 PM, Yan Fang wrote: > Hi Selina, > > > Your understanding is correct. Yes, you "need to consumer the original > input and send it back to Kafka and reset the* Key to departmentName *and > then consume it

Re: questions of partition and task of Samza

Hi, Yan: Thanks a lot for your reply. You mentioned "if you give the msgs the same partition key", which mean same partition key value or same partition key attribute name? I mentioned "primary key" as "key" at public KeyedMessage(java.lang.String topic, K key, V message) or