Hi, Is there any libraries or any other way to implement top-k quality extraction algorithm (top-k info per window/batch) to the existing Kafka, which enable the consumer to get the top-k quality information once the consumer subscribed to a particular topic.
Scenario: Producer free to produce message and once the subscriber subscribed to a particular topic, subscriber will be able to get top k quality information per batch/window as Kafka processed/ Thanks.
