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
3 freelancers are bidding on average $15 for this job
I have lots of experience in data typing, data entry, web research, database administration, ad posting, data research, data mining, data extracting, data scraping, virtual assistant. I hope your kind response.