I would like to implement a functionality in my scala and kafka stream application.
Every message I receive in kafka has a “id” or “name” key attribute and a “status” in the avro schema. So for every message I receive I would like to check the “status” of each “id” and whenever a “Id” has it’s “status” changed from previous message to a different “status” in new message send that record to a output topic
7 freelancers are bidding on average $34 for this job
Hi Sir /Madam I'm really interested in assisting you with this task. I am a qualified document specialist / data analyst with 10yrs experience. I would be grateful if you considered me for this project. Many thanks.
I am currently working as a data scientist and have good knowledge on spark with scala and java along with kafka and working with avro file format. I am looking forward to work in this senario. Thanks