Kafka topic - Compare previous message with a new message

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

Квалификация: Cloud Data, Data Analytics, Scala

Показать больше screenshots output jpg mail send, vbscript compare previous row, compare previous mysql, perl script compare file create xls output, mysql compare previous record current record, peachtree output invoice record, uncaught exception webserviceexception message invalid owner record, freelancer com api check new message, marketing level 4 assignment1 seeking answers question draw a graph to show how the new product will go through the different st, kafka topic, kafka topic authorization, why does adams compare the new technology to religion, post a new message to slack whenever a google sheets row is updated, fatal error uncaught exception tcpdf error some data has already been output can t send pdf file, spark streaming read from kafka topic, message rate limit reached based on queue's max msg rate in configuration, chat app using firebase: get notification when new message received - android, unix compare two files and output differences, compare 2 files and output difference, create kafka topic in java

О работодателе:
( 1 отзыв ) Bellevue, United States

ID проекта: #23937617

3 фрилансеров(-а) в среднем готовы выполнить эту работу за $15

$25 USD за 1 день
(0 отзывов(-а))

========>Your satisfaction is our career<======= i am Farhin. Data processing expert who knows the value of time, very hard working and always delivers the work on time .my motive is to make my employer happy without Больше

$10 USD за 1 день
(0 отзывов(-а))

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.

$10 USD за 7 дней(-я)
(0 отзывов(-а))