I'm following the ConsumerGroup example,

https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example

How can I specify the batch size of the messages that I want to consume? I
see that if I use the SimpleConsumer, I can specify a size that I want to
read. How can I do it here with the ConsumerGroup? I want to be able to
consume let's say 1000 records, process them and so on...

Reply via email to