kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zhilong wang <wangzhilong0...@gmail.com>
Subject Serious problem
Date Fri, 06 Jan 2017 07:12:19 GMT
flume-kafka-sink send message to kafka-0.9




06 Jan 2017 13:13:36,595 ERROR
[SinkRunner-PollingRunner-DefaultSinkProcessor]
(org.apache.flume.SinkRunner$PollingRunner.run:158)  - Unable to deliver
event. Exception follows
org.apache.flume.EventDeliveryException: Failed to publish events
at org.apache.flume.sink.kafka.KafkaSink.process(KafkaSink.java:252)
at
org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:67)
at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:145)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.RecordTooLargeException: The message is
2742363 bytes when serialized which is larger than th
e maximum request size you have configured with the max.request.size
configuration.
at
org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:686)
at
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:449)
at org.apache.flume.sink.kafka.KafkaSink.process(KafkaSink.java:212)
... 3 more
Caused by: org.apache.kafka.common.errors.RecordTooLargeException: The
message is 2742363 bytes when serialized which is larger than the maximum
request size you have configure
d with the max.request.size configuration.

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