kafka.message.InvalidMessageException: Compacted topic cannot accept message without key. at kafka.message.ByteBufferMessageSet.validateMessagesAndAssignOffsets(ByteBufferMessageSet.scala:250)

narkive.com | 8 months ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    trouble upgrading from 0.8.2.1 to 0.9.0.0: invalid message

    narkive.com | 8 months ago
    kafka.message.InvalidMessageException: Compacted topic cannot accept message without key. at kafka.message.ByteBufferMessageSet.validateMessagesAndAssignOffsets(ByteBufferMessageSet.scala:250)

    Root Cause Analysis

    1. kafka.message.InvalidMessageException

      Compacted topic cannot accept message without key. at kafka.message.ByteBufferMessageSet.validateMessagesAndAssignOffsets(ByteBufferMessageSet.scala:250)

      at kafka.log.Log.liftedTree1$1()
    2. Apache Kafka
      CoreUtils$.inReadLock
      1. kafka.log.Log.liftedTree1$1(Log.scala:327)
      2. kafka.log.Log.append(Log.scala:326)
      3. kafka.cluster.Partition$$anonfun$9.apply(Partition.scala:442)
      4. kafka.cluster.Partition$$anonfun$9.apply(Partition.scala:428)
      5. kafka.utils.CoreUtils$.inLock(CoreUtils.scala:262)
      6. kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:268)
      6 frames