"proto: can't skip unknown wire type 4" error when consuming snappy compressed messages

Thanks for taking the time to help me out 😄

Versions

Sarama	Kafka	Go
1.26.1	2.4.0	1.13

Configuration

What configuration values are you using for Sarama and Kafka?

// Sarama config
config := sarama.NewConfig()
config.Version = sarama.V2_4_0_0
sarama.Logger = lognew.New(os.Stdout, "[SARAMA]", os.O_TRUNC)
config.Consumer.Offsets.Initial = sarama.OffsetOldest
consumerGroup, err := sarama.NewConsumerGroup([]string{"localhost:9092"}, "group_id", config)
if err != nil {
    panic(err)
}
client.consumerGroup = consumerGroup

// Consumer Logic
type messageHandler struct {
    callbackReceivers map[string]message.Receiver
}

func (mh *messageHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error {
    for msg := range claim.Messages() {
        log.Debug(fmt.Sprintf("Message topic:%q partition:%d offset:%d\n", msg.Topic, msg.Partition, msg.Offset))

        event := &event.Event{}
        err := proto.Unmarshal(msg.Value, event)
        if err != nil {
            fmt.Println("ERROR: ", err) 
            return nil
        }
    }

    // Do actual computation
}

Kafka config

/usr/bin/kafka-topics --describe --zookeeper zookeeper:2181 --topic mock_topic

Topic: mock_topic     PartitionCount: 1       ReplicationFactor: 1  Configs:compression.type=snappy

Topic: mock_topic     Partition: 0    Leader: 1       Replicas: 1     Isr: 1

Logs

logs: CLICK ME

``` proto: can't skip unknown wire type 4 [SARAMA]consumer/broker/1 closed dead subscription to mock_topic/0 [SARAMA]client/metadata fetching metadata for [mock_topic] from broker localhost:9092 [SARAMA]loop check partition number coroutine will exit, topics [mock_topic] [SARAMA]client/coordinator requesting coordinator for consumergroup hermes-cart-updates-group-id from localhost:9092 [SARAMA]client/coordinator coordinator for consumergroup hermes-cart-updates-group-id is #1 (localhost:9092) [SARAMA]consumer/broker/1 added subscription to mock_topic/0 ```

Problem Description

Error when running proto.Unmarshal(msg.Value, event) when using snappy

Not using Snappy compression during produce -> Unmarshal is successful
Using Snappy compression during produce -> Unmarshal throws error proto: can't skip unknown wire type 4.

If my understanding is correct, this article states that "The consumer thread dequeues data from this blocking queue, decompresses and iterates through the messages", which means any message my consumer consumes should already be decompressed. But matching the byte array of both compressed/uncompressed msg.Value is different. What am I missing here😕?

IBM / sarama