[jira] [Commented] (KAFKA-3657) NewProducer NullPointerException on ProduceRequest
[
https://issues.apache.org/jira/browse/KAFKA-3657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16111352#comment-16111352
]
Shubham Rander commented on KAFKA-3657:
---
[~ijuma] We have seen the same issue intermittently with 0.9.x version.
Thanks
> NewProducer NullPointerException on ProduceRequest
> --
>
> Key: KAFKA-3657
> URL: https://issues.apache.org/jira/browse/KAFKA-3657
> Project: Kafka
> Issue Type: Bug
> Components: network, producer
>Affects Versions: 0.8.2.1
> Environment: linux 3.2.0 debian7
>Reporter: Vamsi Subhash Achanta
>Assignee: Jun Rao
>
> The producer upon send.get() on the future appends to the accumulator the
> record batches and the Sender.java (separate thread) flushes it to the
> server. The produce request waits on the countDownLatch in the
> FutureRecordMetadata:
> public RecordMetadata get() throws InterruptedException,
> ExecutionException {
> this.result.await();
> In this case, the client thread is blocked for ever (as it is get() without
> timeout) for the response and the response upon poll by the Sender returns an
> attachment with the batch value as null. The batch is processed and the
> request is errored out. The Sender catches a global level exception and then
> goes ahead. As the accumulator is drained, the response will never be
> returned and the producer client thread calling get() is blocked for ever on
> the latch await call.
> I checked at the server end but still haven't found the reason for null
> batch. Any pointers on this?
> ERROR [2016-05-01 21:00:09,256] [kafka-producer-network-thread |producer-app]
> [Sender] message_id: group_id: : Uncaught error in kafka producer I/O thread:
> ! java.lang.NullPointerException: null
> ! at
> org.apache.kafka.clients.producer.internals.Sender.completeBatch(Sender.java:266)
> ! at
> org.apache.kafka.clients.producer.internals.Sender.handleResponse(Sender.java:236)
> ! at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:196)
> ! at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
> ! at java.lang.Thread.run(Thread.java:745)
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
[jira] [Commented] (KAFKA-3657) NewProducer NullPointerException on ProduceRequest
[
https://issues.apache.org/jira/browse/KAFKA-3657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16223618#comment-16223618
]
Ismael Juma commented on KAFKA-3657:
It would be good to know if anyone has seen this with more recent versions.
Also, it would be good to know the broker and producer versions (in case they
are not the same).
> NewProducer NullPointerException on ProduceRequest
> --
>
> Key: KAFKA-3657
> URL: https://issues.apache.org/jira/browse/KAFKA-3657
> Project: Kafka
> Issue Type: Bug
> Components: network, producer
>Affects Versions: 0.8.2.1, 0.9.0.1
> Environment: linux 3.2.0 debian7
>Reporter: Vamsi Subhash Achanta
>Assignee: Jun Rao
> Labels: reliability
>
> The producer upon send.get() on the future appends to the accumulator the
> record batches and the Sender.java (separate thread) flushes it to the
> server. The produce request waits on the countDownLatch in the
> FutureRecordMetadata:
> public RecordMetadata get() throws InterruptedException,
> ExecutionException {
> this.result.await();
> In this case, the client thread is blocked for ever (as it is get() without
> timeout) for the response and the response upon poll by the Sender returns an
> attachment with the batch value as null. The batch is processed and the
> request is errored out. The Sender catches a global level exception and then
> goes ahead. As the accumulator is drained, the response will never be
> returned and the producer client thread calling get() is blocked for ever on
> the latch await call.
> I checked at the server end but still haven't found the reason for null
> batch. Any pointers on this?
> ERROR [2016-05-01 21:00:09,256] [kafka-producer-network-thread |producer-app]
> [Sender] message_id: group_id: : Uncaught error in kafka producer I/O thread:
> ! java.lang.NullPointerException: null
> ! at
> org.apache.kafka.clients.producer.internals.Sender.completeBatch(Sender.java:266)
> ! at
> org.apache.kafka.clients.producer.internals.Sender.handleResponse(Sender.java:236)
> ! at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:196)
> ! at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
> ! at java.lang.Thread.run(Thread.java:745)
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
