Hi prabhjot I just realized its not producing to kafka that’s why iam getting this null pointer. In my localhost I can see kafka info/debug logs. But in HDP cluster I cannot see any exceptions. How should I configure the logger to show exceptions in kafka log files thanks
-----Original Message----- From: Prabhjot Bharaj [mailto:prabhbha...@gmail.com] Sent: 25 November 2015 17:35 To: us...@kafka.apache.org Cc: dev@kafka.apache.org Subject: Re: kafka 0.8 producer issue Hi, From the information that you've provided, I think your callback is the culprit here. It is seen from the stacktrace:- at com.hpe.ssmamp.kafka.KafkaPDFAProducer$1.onCompletion( KafkaPDFAProducer.java:62) Please provide more information like a code snippet etc, so that we can tell more Thanks, Prabhjot On Wed, Nov 25, 2015 at 9:24 PM, Kudumula, Surender < surender.kudum...@hpe.com> wrote: > Hi all > I am trying to get the producer working. It was working before but now > getting the following issue. I have created a new topic as well just > in case if it was the issue with topic but still no luck. I have > increased the message size in broker as iam trying to send atleast 3mb > message here in byte array format. Any suggestion please??? > > 2015-11-25 15:46:11 INFO Login:185 - TGT refresh sleeping until: Tue > Dec > 01 07:03:07 GMT 2015 > 2015-11-25 15:46:11 INFO KafkaProducer:558 - Closing the Kafka > producer with timeoutMillis = 9223372036854775807 ms. > 2015-11-25 15:46:12 ERROR RecordBatch:96 - Error executing > user-provided callback on message for topic-partition ResponseTopic-0: > java.lang.NullPointerException > at > com.hpe.ssmamp.kafka.KafkaPDFAProducer$1.onCompletion(KafkaPDFAProducer.java:62) > at > org.apache.kafka.clients.producer.internals.RecordBatch.done(RecordBatch.java:93) > at > org.apache.kafka.clients.producer.internals.Sender.completeBatch(Sender.java:285) > at > org.apache.kafka.clients.producer.internals.Sender.handleProduceResponse(Sender.java:253) > at > org.apache.kafka.clients.producer.internals.Sender.access$100(Sender.java:55) > at > org.apache.kafka.clients.producer.internals.Sender$1.onComplete(Sender.java:328) > at > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:237) > at > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:209) > at > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:140) > at java.lang.Thread.run(Thread.java:745) > > > > -- --------------------------------------------------------- "There are only 10 types of people in the world: Those who understand binary, and those who don't"
