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)