How you do this in the high level consumer is slightly different. First,
set the auto offset commit property to false. Then you can keep reading
messages from kafka and when you're done filling up your buffer, commit
offsets manually. The following link gives an example:
http://ingest.tips/2014/10
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 th
