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 <gaurav130...@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.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) > > > > > > > > > -- Thanks Raju Bairishetti, www.lazada.com
