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.

GitHub | Tracy6465 | 6 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    kafka.common.MessageSizeTooLargeException

    GitHub | 6 months ago | Tracy6465
    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.
  2. 0

    GitHub comment 216#105832612

    GitHub | 2 years ago | dsdinter
    kafka.common.MessageSizeTooLargeException: Found a message larger than the maximum fetch size of this consumer on topic OryxUpdate partition 1 at fetch offset 31040247. Increase the fetch size, or decrease the maximum message size the br oker will allow.
  3. 0

    Kafka kafka.common.MessageSizeTooLargeException at consumer

    Stack Overflow | 1 year ago | Kedar Parikh
    kafka.common.MessageSizeTooLargeException: 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.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Setting fetch.max.message.bytes doesn't work

    GitHub | 1 year ago | Nesze
    kafka.common.MessageSizeTooLargeException: 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.

    Root Cause Analysis

    1. 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()
    2. Apache Kafka
      IteratorTemplate.hasNext
      1. kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:91)
      2. kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33)
      3. kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
      4. kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58)
      4 frames
    3. org.apache.flume
      KafkaSource.process
      1. org.apache.flume.source.kafka.KafkaSource.hasNext(KafkaSource.java:248)
      2. org.apache.flume.source.kafka.KafkaSource.process(KafkaSource.java:97)
      2 frames
    4. Flume
      PollableSourceRunner$PollingRunner.run
      1. org.apache.flume.source.PollableSourceRunner$PollingRunner.run(PollableSourceRunner.java:139)
      1 frame
    5. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame