Hi, I have just started looking at moving from 0.7 to 0.8 and wanted to confirm my understanding of code in the message server/broker.
In the code for 0.8, KafkaApis.appendToLocalLog calls log.append(..., assignOffsets = true), which then calls ByteBufferMessageSet.assignOffsets. This method seems to uncompress and then re-compress the entire set of messages. Is my understanding of the code correct? Has any testing been done on the CPU consumption / performance of the message server to determine whether this adversely impacts message throughput under high load? Thanks, Ross
