Still struggling :)
Check following threads;

   - If my producer producing, then why the consumer couldn't consume? it
   stuck @ poll()
   - Consumer thread is waiting forever, not returning any objects


I think new APIs are recommended.


On 4 April 2016 at 16:37, Lohith Samaga M <lohith.sam...@mphasis.com> wrote:

> Thanks for letting me know.
>
> Is there any work around? A fix?
>
> Which set of API is recommended for production use?
>
> Best regards / Mit freundlichen Grüßen / Sincères salutations
> M. Lohith Samaga
>
>
>
>
> -----Original Message-----
> From: Ratha v [mailto:vijayara...@gmail.com]
> Sent: Monday, April 04, 2016 11.27
> To: users@kafka.apache.org
> Subject: Re: New consumer API waits indefinitely
>
> I too face same issue:(
>
> On 4 April 2016 at 15:51, Lohith Samaga M <lohith.sam...@mphasis.com>
> wrote:
>
> > HI,
> >                 Good morning.
> >
> >                 I am new to Kafka. So, please bear with me.
> >                 I am using the new Producer and Consumer API with
> > Kafka
> > 0.9.0.1 running on Windows 7 laptop with zookeeper.
> >
> >                 I was able to send messages using the new Producer
> > API. I can see the messages in the Kafka data directory.
> >
> >                 However, when I run the consumer, it does not retrieve
> > the messages. It keeps waiting for the messages indefinitely.
> >                 My code (taken from Javadoc and modified)  is as below:
> >
> >             props.put("bootstrap.servers", "localhost:9092");
> >             props.put("group.id", "new01");
> >             props.put("enable.auto.commit", "true");
> >             props.put("auto.commit.interval.ms", "1000");
> >             props.put("session.timeout.ms", "30000");
> >             props.put("key.deserializer",
> > "org.apache.kafka.common.serialization.StringDeserializer");
> >             props.put("value.deserializer",
> > "org.apache.kafka.common.serialization.StringDeserializer");
> >
> >             KafkaConsumer<String, String> consumer = new
> > KafkaConsumer<>(props);
> >             consumer.subscribe(Arrays.asList("new-producer"));
> >             while (true) {
> >                 ConsumerRecords<String, String> records =
> > consumer.poll(100);
> >                 for (ConsumerRecord<String, String> record : records)
> >                     System.out.printf("offset = %d, key = %s, value =
> > %s", record.offset(), record.key(), record.value());
> >             }
> >
> >                 Can anybody please tell me what went wrong?
> >
> > Thanks & Regards,
> > M. Lohith Samaga
> >
> > Information transmitted by this e-mail is proprietary to Mphasis, its
> > associated companies and/ or its customers and is intended for use
> > only by the individual or entity to which it is addressed, and may
> > contain information that is privileged, confidential or exempt from
> > disclosure under applicable law. If you are not the intended recipient
> > or it appears that this mail has been forwarded to you without proper
> > authority, you are notified that any use or dissemination of this
> > information in any manner is strictly prohibited. In such cases,
> > please notify us immediately at mailmas...@mphasis.com and delete this
> > mail from your records.
> >
>
>
>
> --
> -Ratha
> http://vvratha.blogspot.com/
> Information transmitted by this e-mail is proprietary to Mphasis, its
> associated companies and/ or its customers and is intended
> for use only by the individual or entity to which it is addressed, and may
> contain information that is privileged, confidential or
> exempt from disclosure under applicable law. If you are not the intended
> recipient or it appears that this mail has been forwarded
> to you without proper authority, you are notified that any use or
> dissemination of this information in any manner is strictly
> prohibited. In such cases, please notify us immediately at
> mailmas...@mphasis.com and delete this mail from your records.
>



-- 
-Ratha
http://vvratha.blogspot.com/

Reply via email to