Compacted topics require keyed messages in order for compaction to
function.  The solution is to provide a key for your messages.  I would
suggest reading the wiki on log compaction.
<https://cwiki.apache.org/confluence/display/KAFKA/Log+Compaction>

On Mon, Jul 18, 2016 at 12:03 PM, Kafka <kafka...@126.com> wrote:

> Hi,
>         The server log shows error as belows on broker 0.9.0.
>         ERROR [Replica Manager on Broker 0]: Error processing append
> operation on partition [__consumer_offsets,5] (kafka.server.ReplicaManager)
> kafka.message.InvalidMessageException: Compacted topic cannot accept
> message without key.
>
> Why does this happen and what’s the solution?
>
>
>


-- 
Dustin Cote
confluent.io

Reply via email to