2 lihe55966 lihe55966 于 2016.02.02 21:44 提问

samza 向kafka写数据报错,求高手啊!!

java version "1.7.0_79"
Java(TM) SE Runtime Environment (build 1.7.0_79-b15)
Java HotSpot(TM) 64-Bit Server VM (build 24.79-b02, mixed mode)
org.apache.samza.SamzaException: Unable to send message from TaskName-Partition 4 to system kafka.
at org.apache.samza.system.kafka.KafkaSystemProducer$$anonfun$flush$1.apply$mcV$sp(KafkaSystemProducer.scala:147)
at org.apache.samza.system.kafka.KafkaSystemProducer$$anonfun$flush$1.apply(KafkaSystemProducer.scala:131)
at org.apache.samza.system.kafka.KafkaSystemProducer$$anonfun$flush$1.apply(KafkaSystemProducer.scala:131)
at org.apache.samza.util.TimerUtils$class.updateTimer(TimerUtils.scala:37)
at org.apache.samza.system.kafka.KafkaSystemProducer.updateTimer(KafkaSystemProducer.scala:39)
at org.apache.samza.system.kafka.KafkaSystemProducer.flush(KafkaSystemProducer.scala:131)
at org.apache.samza.system.kafka.KafkaSystemProducer$$anonfun$stop$1.apply(KafkaSystemProducer.scala:55)
at org.apache.samza.system.kafka.KafkaSystemProducer$$anonfun$stop$1.apply(KafkaSystemProducer.scala:55)
at scala.collection.Iterator$class.foreach(Iterator.scala:727)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
at scala.collection.MapLike$DefaultKeySet.foreach(MapLike.scala:174)
at org.apache.samza.system.kafka.KafkaSystemProducer.stop(KafkaSystemProducer.scala:55)
at org.apache.samza.system.kafka.KafkaSystemProducer$$anonfun$send$5.apply(KafkaSystemProducer.scala:115)
at org.apache.samza.system.kafka.KafkaSystemProducer$$anonfun$send$5.apply(KafkaSystemProducer.scala:111)
at org.apache.samza.util.ExponentialSleepStrategy.run(ExponentialSleepStrategy.scala:81)
at org.apache.samza.system.kafka.KafkaSystemProducer.send(KafkaSystemProducer.scala:86)
at org.apache.samza.system.SystemProducers.send(SystemProducers.scala:87)
at org.apache.samza.task.TaskInstanceCollector.send(TaskInstanceCollector.scala:61)
at org.s

Caused by: org.apache.kafka.common.errors.RecordTooLargeException: The request included a message larger than the max message size the server will accept

1个回答

devmiao
devmiao   Ds   Rxr 2016.02.02 22:17

RecordTooLargeException,消息太大了

Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!