Hi So far I was unable to reproduce. I will try again. The link you pasted gets me to the site but I can’t create an issue - how can I do it ?
Michael On Oct 9, 2017, at 12:38 PM, Manikumar <manikumar.re...@gmail.com<mailto:manikumar.re...@gmail.com>> wrote: Hi, Can you reproduce the error? Is it happening at the same offset every time? Try to reproduce with the console-consumer tool. You can raise JIRA issue here. https://issues.apache.org/jira/projects/KAFKA On Mon, Oct 9, 2017 at 3:00 PM, Michael Keinan <micha...@capitolis.com> wrote: Thank you for your response. No consumer interceptor involved Michael On Oct 8, 2017, at 7:04 PM, Ted Yu <yuzhih...@gmail.com<mailto:yu zhih...@gmail.com>> wrote: Was there any consumer interceptor involved ? Cheers On Sun, Oct 8, 2017 at 6:29 AM, Michael Keinan <micha...@capitolis.com< mailto:micha...@capitolis.com>> wrote: Hi Using Kafka 0.10.2.0 I get a NPE while iterating the records after polling them using poll method. - Any idea where does it come from ? - How can I open an issue to Kafka team ? Stacktrace: java.lang.NullPointerException at org.apache.kafka.clients.consumer.ConsumerRecords$ ConcatenatedIterable$1.makeNext(ConsumerRecords.java:112) at org.apache.kafka.clients.consumer.ConsumerRecords$ ConcatenatedIterable$1.makeNext(ConsumerRecords.java:101) at org.apache.kafka.common.utils.AbstractIterator.maybeComputeNext( AbstractIterator.java:79) at org.apache.kafka.common.utils.AbstractIterator.hasNext( AbstractIterator.java:45) at com.capitolis.messagespersistency.KafkaListener.listen( KafkaListener.java:104) My code while (true) { ConsumerRecords<String, String> records = consumer.poll(timeout); (Error occurs here—>) for (ConsumerRecord<String, String> record : records) { String value = record.value(); } Michael Keinan
