Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-13953

kafka Console consumer fails with CorruptRecordException

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Blocker
    • Resolution: Unresolved
    • 2.7.0
    • None
    • consumer, controller, core
    • None

    Description

      Kafka consumer fails with corrupt record exception. 

      opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server *.*.*.*:<port> --topic BQR-PULL-DEFAULT --from-beginning > /opt/nokia/kafka-zookeeper-clustering/kafka/topic-data/tmpsdh/dumptest
      [{*}2022-05-15 18:34:15,146]{*} ERROR Error processing message, terminating consumer process:  (kafka.tools.ConsoleConsumer$)
      org.apache.kafka.common.KafkaException: Received exception when fetching the next record from BQR-PULL-DEFAULT-30. If needed, please seek past the record to continue consumption.
              at org.apache.kafka.clients.consumer.internals.Fetcher$CompletedFetch.fetchRecords(Fetcher.java:1577)
              at org.apache.kafka.clients.consumer.internals.Fetcher$CompletedFetch.access$1700(Fetcher.java:1432)
              at org.apache.kafka.clients.consumer.internals.Fetcher.fetchRecords(Fetcher.java:684)
              at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:635)
              at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1276)
              at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1237)
              at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1210)
              at kafka.tools.ConsoleConsumer$ConsumerWrapper.receive(ConsoleConsumer.scala:438)
              at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:104)
              at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:78)
              at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:55)
              at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
      Caused by: org.apache.kafka.common.errors.CorruptRecordException: Record size 0 is less than the minimum record overhead (14)
      Processed a total of 15765197 messages 

      Attachments

        Activity

          People

            Unassigned Unassigned
            abasilbr Aldan Brito
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated: