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 | 3 months ago
  1. 0

    kafka.common.MessageSizeTooLargeException

    GitHub | 3 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.
  6. 0

    MessageSizeTooLargeException when consuming the topic

    GitHub | 2 weeks ago | goblinhecker
    kafka.common.MessageSizeTooLargeException: 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.

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    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