'How to conditionally poll messages from Kafka Topic

I have a few task notifications in a MongoDB database. Each task has a due_date and reminder flag. I am pushing these tasks to a Kafka Topic. There is a Node JS app that polls from this topic and pushes notifications to a frontend app based on the due_date and reminder flag. The due_date could be past dated or upcoming.

From Kafka we need to send notifications to the Node App that is listening whenever those conditions time-based conditions occur:

  1. Reminder = true and it is X time before the Due Date
  2. Due Date = now
  3. The Task still exists and is Past Due

How can this be done with Kafka?

node.jsapache-kafkakafka-consumer-apiapache-kafka-connect


Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source

Related Questions