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






Reply via email to