What makes you think there are 2? would you have data or code to share?

When compression is enabled, multiple messages will be packed and
compressed in a MessageSet. That MessageSet will then have a single message.
The interface however will let you iterate over the unpacked messages. See
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/message/ByteBufferMessageSet.scala#L166


https://github.com/apache/kafka/blob/trunk/core/src/test/scala/unit/kafka/message/ByteBufferMessageSetTest.scala



On Tue, Feb 16, 2016 at 3:33 AM Oleksiy Krivoshey <oleks...@gmail.com>
wrote:

> Hi!
>
> The Kafka 0.9 protocol guide
>
> https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-Compression
> explicitly
> states that there should be only single compressed message in a MessageSet,
> but I'm definitely receiving two compressed messages in a single
> MessageSet.
>
> Can someone please confirm if this should be expected behaviour?
>
> Thanks!
>

Reply via email to