Hi team, Say we have a client which has pushed a message to a topic. The message has a a simple structure
Task - Time of task Send an email - 1530 Now say that this message is consumed by a consumer subscribed to this topic. Since Topic already has a storage, what I intend to do is just read the message (not poll it) and see if it is before 1530 then send it to the tail of the partition of that topic. Does Kafka provide such an Api? Next time when the consumer reads the message and see if the current time is after 1530, it will poll the message and execute the task. Regards Gagan
