The inner loop keeps running. If I break it in the middle, is Kafka broker
going to know that rest of the mesaages in the stream were not delivered?
Regards,
Vaibhav
GumGum
On Jul 11, 2012 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
>
>
>
