avillev opened a new issue #6166: Windowed consumers/functions URL: https://github.com/apache/pulsar/issues/6166 Using Kafka Streams, I was able to use WindowedStreams to filter and rate limit the events of a topic over time based on event priorities. Ex: Only 5 messages are accepted per second. We only take the most important ones within one second. I have been checking Pulsar functions to achieve the same thing and could not find a way. I would love to have the possibility in a pulsar function or in a consumer, to consume/process windowed batches of elements to be able to do the same thing.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
