kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bo Sun <docsun...@gmail.com>
Subject Payload size exception
Date Tue, 29 Jan 2013 08:18:19 GMT
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

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