Re: Previous State of a Kafka Message

2020-12-07 Thread Suresh Chidambaram
Hi Andrew, Thank you for the suggestion. Creating the custom Processor helped me achieving the requirement. Thank you once again. Thanks C Suresh On Sunday, December 6, 2020, Andrew Grant wrote: > Hi Suresh, > > It seems the keys are different for each message - I see 0, 1 and 2. When > you sa

Re: Previous State of a Kafka Message

2020-12-06 Thread Andrew Grant
Hi Suresh, It seems the keys are different for each message - I see 0, 1 and 2. When you say "This topic contains the same keys" do you mean the message contents contain the same "attr1" "attr2" "attr3" keys? If so, I think the first step would be to re-key the messages so the new key is "attr1:at

Previous State of a Kafka Message

2020-12-06 Thread Suresh Chidambaram
Hi, Greetings! My requirement is as below. I have Topic named "sample-topic". This topic contains the same keys(as String) with multiple messages and the messages are in JSON format. I would like to merge the JSON messages and produce a final JSON. In order to achieve this, how to maintain the