Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Payload size exception


Copy link to this message
-
Payload size exception
hi all
i've got a exception .
kafka.common.MessageSizeTooLargeException: payload size of 1772597 larger
than 1000000
        at
kafka.message.ByteBufferMessageSet.verifyMessageSize(ByteBufferMessageSet.scala:93)
        at kafka.producer.SyncProducer.send(SyncProducer.scala:122)
        at
kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:114)
        at
kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:100)
        at
kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:100)
        at
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
        at
scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
        at kafka.producer.ProducerPool.send(ProducerPool.scala:100)
        at kafka.producer.Producer.zkSend(Producer.scala:140)
        at kafka.producer.Producer.send(Producer.scala:99)
        at kafka.javaapi.producer.Producer.send(Producer.scala:103)

i dont know why. plz help me .thanks