kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Raju Bairishetti <raju....@gmail.com>
Subject Re: kafka 0.8 producer issue
Date Sat, 05 Dec 2015 00:25:45 GMT
For setting up logs for kafka, we need to export KAFKA_LOG4J_OPS env
variable before starting the kafka servers. if log4j.properties is
presented in /etc/kafka/ directory then it will be directly picks otherwise
it uses tools-log4j.properties from /etc/kafka.

You can set the location of server logs by setting kafka.logs.dir in the
/etc/kafka/log4j properties.

On Thu, Nov 26, 2015 at 2:50 PM, Gaurav Agarwal <gaurav130403@gmail.com>
wrote:

> Can u share the code that you are using to publish the message. Also can u
> whether a small message is.published
> On Nov 25, 2015 9:25 PM, "Kudumula, Surender" <surender.kudumula@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)
> >
> >
> >
> >
>



-- 
Thanks
Raju Bairishetti,

www.lazada.com

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message