Was there any consumer interceptor involved ?
Cheers
On Sun, Oct 8, 2017 at 6:29 AM, Michael Keinan <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
>
>
>
>
>
>
>
