kafka.common.MessageSizeTooLargeException: Found a message larger than the maximum fetch size of this consumer on topic ystmo partition 0 at fetch offset 4. Increase the fetch size, or decrease the maximum message size the broker will allow.

Searched on Google with the first line of a JAVA stack trace?

We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.

Recommended solutions based on your search

Samebug tips

Do you know how to solve this issue? Write a tip to help other users and build your expert profile.

Solutions on the web

via GitHub by Tracy6465
, 1 year ago
Found a message larger than the maximum fetch size of this consumer on topic ystmo partition 0 at fetch offset 4. Increase the fetch size, or decrease the maximum message size the broker will allow.
via GitHub by Nesze
, 2 years ago
Found a message larger than the maximum fetch size of this consumer on topic PublicationEvents partition 6 at fetch offset 2134. Increase the fetch size, or decrease the maximum message size the broker will allow.
via GitHub by goblinhecker
, 10 months ago
Found a message larger than the maximum fetch size of this consumer on topic <topic> partition 0 at fetch offset 0. Increase the fetch size, or decrease the maximum message size the broker will allow.
via Stack Overflow by Kedar Parikh
, 2 years ago
Found a message larger than the maximum fetch size of this consumer on topic xyz partition 0 at fetch offset 29. Increase the fetch size, or decrease the maximum message size the broker will allow.
via GitHub by hyperlink
, 1 year ago
Found a message larger than the maximum fetch size of this consumer on topic ProducerConnectivityTest partition 1 at fetch offset 41. Increase the fetch size, or decrease the maximum message size the broker will allow.
via Stack Overflow by Praveen
, 5 months ago
Found a message larger than the maximum fetch size of this consumer on topic Topic1 partition 9 at fetch offset 5. Increase the fetch size, or decrease the maximum message size the broker will allow.
kafka.common.MessageSizeTooLargeException: Found a message larger than the maximum fetch size of this consumer on topic ystmo partition 0 at fetch offset 4. Increase the fetch size, or decrease the maximum message size the broker will allow.
at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:91)
at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33)
at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58)
at org.apache.flume.source.kafka.KafkaSource.hasNext(KafkaSource.java:248)
at org.apache.flume.source.kafka.KafkaSource.process(KafkaSource.java:97)
at java.lang.Thread.run(Thread.java:745)

Users with the same issue

You are the first who have seen this exception. Write a tip to help other users and build your expert profile.

Write tip

Know the solutions? Share your knowledge to help other developers to debug faster.