Search on queue?

[Manish Degan <de...@gmail.com>]

Hi,

I have been thinking of some high volume use cases where I want to utilize
Kafka. The message objects in my queue might have a date property. I want
to pull all messages till a date to perform certain actions. Currently, I
can continue listening but cannot confirm if there are any more messages
for the date which might still be in the queue. Would it be a good idea to
have configurable search props in a wrapper object that comes to Kafka and
for the users to use the field set by them for searches? Bit of complicated
use case but might be a good functionality.

Regards,
Manish