You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Michael Keinan <mi...@capitolis.com> on 2017/10/08 13:29:31 UTC

NPE on ConsumerRecords$ConcatenatedIterable$1.makeNext() while iterating records

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

Re: NPE on ConsumerRecords$ConcatenatedIterable$1.makeNext() while iterating records

Posted by Manikumar <ma...@gmail.com>.
sign up for JIRA account and login to create an issue.

On Tue, Oct 10, 2017 at 1:50 PM, Michael Keinan <mi...@capitolis.com>
wrote:

> 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.reddy@gmail.com<mailto:
> manikumar.reddy@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 <mi...@capitolis.com>
> wrote:
>
> Thank you for your response.
> No consumer interceptor involved
>
> Michael
>
>
>
>
> On Oct 8, 2017, at 7:04 PM, Ted Yu <yuzhihong@gmail.com<mailto:yu
> zhihong@gmail.com>> wrote:
>
> Was there any consumer interceptor involved ?
>
> Cheers
>
> On Sun, Oct 8, 2017 at 6:29 AM, Michael Keinan <michaelk@capitolis.com<
> mailto:michaelk@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
>
>
>
>
>
>
>
>
>
>
>

Re: NPE on ConsumerRecords$ConcatenatedIterable$1.makeNext() while iterating records

Posted by Michael Keinan <mi...@capitolis.com>.
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 <ma...@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 <mi...@capitolis.com>
wrote:

Thank you for your response.
No consumer interceptor involved

Michael




On Oct 8, 2017, at 7:04 PM, Ted Yu <yuzhihong@gmail.com<mailto:yu
zhihong@gmail.com>> wrote:

Was there any consumer interceptor involved ?

Cheers

On Sun, Oct 8, 2017 at 6:29 AM, Michael Keinan <michaelk@capitolis.com<
mailto:michaelk@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

Re: NPE on ConsumerRecords$ConcatenatedIterable$1.makeNext() while iterating records

Posted by Manikumar <ma...@gmail.com>.
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 <mi...@capitolis.com>
wrote:

> Thank you for your response.
> No consumer interceptor involved
>
> Michael
>
>
>
>
> On Oct 8, 2017, at 7:04 PM, Ted Yu <yuzhihong@gmail.com<mailto:yu
> zhihong@gmail.com>> wrote:
>
> Was there any consumer interceptor involved ?
>
> Cheers
>
> On Sun, Oct 8, 2017 at 6:29 AM, Michael Keinan <michaelk@capitolis.com<
> mailto:michaelk@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
>
>
>
>
>
>
>
>
>

Re: NPE on ConsumerRecords$ConcatenatedIterable$1.makeNext() while iterating records

Posted by Michael Keinan <mi...@capitolis.com>.
Thank you for your response.
No consumer interceptor involved

Michael




On Oct 8, 2017, at 7:04 PM, Ted Yu <yu...@gmail.com>> wrote:

Was there any consumer interceptor involved ?

Cheers

On Sun, Oct 8, 2017 at 6:29 AM, Michael Keinan <mi...@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

Re: NPE on ConsumerRecords$ConcatenatedIterable$1.makeNext() while iterating records

Posted by Ted Yu <yu...@gmail.com>.
Was there any consumer interceptor involved ?

Cheers

On Sun, Oct 8, 2017 at 6:29 AM, Michael Keinan <mi...@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
>
>
>
>
>
>
>

Re: NPE on ConsumerRecords$ConcatenatedIterable$1.makeNext() while iterating records

Posted by Ismael Juma <is...@juma.me.uk>.
Can you please try with a newer version? Either 0.10.2.1 or 0.11.0.1?

Ismael

On Sun, Oct 8, 2017 at 2:29 PM, Michael Keinan <mi...@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
>
>
>
>
>
>
>