Thank You. I will try this out.
On Thu, Sep 25, 2014 at 10:01 PM, Gwen Shapira
wrote:
> Using high level consumer and assuming you already created an iterator:
>
> while (msgCount < maxMessages && it.hasNext()) {
> bytes = it.next().message();
> eventList.add(bytes);
> }
>
> (See a complete ex
Using high level consumer and assuming you already created an iterator:
while (msgCount < maxMessages && it.hasNext()) {
bytes = it.next().message();
eventList.add(bytes);
}
(See a complete example here:
https://github.com/apache/flume/blob/trunk/flume-ng-sources/flume-kafka-source/src/main/jav
