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