Well, you can control how many messages to iterate in the application.
Thanks,
Jun
On Wed, Jul 11, 2012 at 5:05 PM, Vaibhav Puranik <vpura...@gmail.com> wrote:
> Hi all,
>
> Is there any way to get a fixed amount of messages using Zookeeper based
> consumer (ConsumerConnector)?
>
> I know that with SimpleConsumer you can pass fetchSize as an argument and
> limit the number of messages coming back.
>
> This sample code creates 4 threads that keep consuming forever.
>
> // consume the messages in the threads
> for(final KafkaStream<Message> stream: streams) {
> executor.submit(new Runnable() {
> public void run() {
> for(MessageAndMetadata msgAndMetadata: stream) {
> // process message (msgAndMetadata.message())
> }
> }
> });
> }
>
> Regards,
> Vaibhav
>
