Hey Guys, So I'm writing my custom job in Samza and wanted to make sure I'm not re-inventing the wheel.
I have a kafka job running that reads from a csv file and writes to a topic. I wrote this using the kafka producer api independent of Samza. The output is a KeyedMessage with key being my eventId and the value is a string corresponding to my event. Now, I want to write a SamzaConsumer that listens on my topic, parses the string to retrieve specific fields I'm interested in and write it out to a different kafka topic. Are there existing classes I can leverage to do this? Thanks, Sonali Sonali Parthasarathy R&D Developer, Data Insights Accenture Technology Labs 703-341-7432 ________________________________ This message is for the designated recipient only and may contain privileged, proprietary, or otherwise confidential information. If you have received it in error, please notify the sender immediately and delete the original. Any other use of the e-mail by you is prohibited. Where allowed by local law, electronic communications with Accenture and its affiliates, including e-mail and instant messaging (including content), may be scanned by our systems for the purposes of information security and assessment of internal compliance with Accenture policy. ______________________________________________________________________________________ www.accenture.com
