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