Question - Accomulate N messages in T duration or timeout.

[ajosecueto]

I would like use poll with a specified timeout but i would like to get N number of messages per call. And poll other messages in the next call.

consumer.iter().take(1000) // Acomulate messages 

I would like to acomulate this messages but based in a specified Duration or Timeout.