kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ismael Juma (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-5456) Producer fails with NPE if record is larger than batch size
Date Fri, 16 Jun 2017 15:42:00 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052047#comment-16052047
] 

Ismael Juma commented on KAFKA-5456:
------------------------------------

The JIRA states that this affects 0.10.2.1 as well, but is that true? Looking at the code,
it seems like it doesn't have the same issue.

> 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.11.0.0, 0.10.2.1
>            Reporter: Matthias J. Sax
>            Assignee: Jason Gustafson
>            Priority: Blocker
>             Fix For: 0.11.0.0
>
>
> 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