kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-5456) Producer fails with NPE if record is larger than batch size
Date Thu, 15 Jun 2017 23:47:00 GMT
Matthias J. Sax created KAFKA-5456:
--------------------------------------

             Summary: Producer fails with NPE if record is larger than batch size
                 Key: KAFKA-5456
                 URL: https://issues.apache.org/jira/browse/KAFKA-5456
             Project: Kafka
          Issue Type: Bug
          Components: producer 
    Affects Versions: 0.10.2.1, 0.11.0.0
            Reporter: Matthias J. Sax


If a record exceed the producer's configure batch size on {{send()}}, producer fails with
a NPE

>From mailing list:
{quote}
java.lang.NullPointerException

at org.apache.kafka.common.utils.Utils.notNull(Utils.java:243)
at
org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:219)
at
org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:650)
at
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:604)
at
org.apache.kafka.streams.processor.internals.RecordCollectorImpl.send(RecordCollectorImpl.java:97)
at
org.apache.kafka.streams.state.internals.StoreChangeLogger.logChange(StoreChangeLogger.java:59)
at
...
{quote}

The NPE is not very helpful and we should have a proper exception type and meaningful exception
message that points the user to the config they need to change to fix the problem. We also
need to add a test for this.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message