消费kafka不需要设置 压缩协议吗 假如生产者压缩协议是lz4

package main

import (
    "github.com/Shopify/sarama"
    "go.uber.org/zap"
)

func main() {
    brokers := []string{"broker1:9092", "broker2:9092"}
    topic := "your_topic"

    // 创建 Sarama 配置
    config := sarama.NewConfig()
    config.Consumer.Return.Errors = true
    config.Version = sarama.V2_1_0_0 // 使用 Kafka 版本

    // 创建消费者
    client, err := sarama.NewConsumer(brokers, config)
    if err != nil {
        zap.S().Fatal(err)
    }
    defer func() {
        if err := client.Close(); err != nil {
            zap.S().Errorf("client close error: %v", err)
        }
    }()

    // 获取分区列表
    partitions, err := client.Partitions(topic)
    if err != nil {
        zap.S().Fatal(err)
    }

    // 选择偏移量
    offset := sarama.OffsetOldest
    zap.S().Infof("start one offset: %d", offset)

    // 消费第一个分区
    claim, err := client.ConsumePartition(topic, partitions[0], offset)
    if err != nil {
        zap.S().Fatal(err)
    }
    defer func() {
        zap.S().Infof("kafka is closing...")
        if err := claim.Close(); err != nil {
            zap.S().Errorf("partition consumer close error: %v", err)
        }
    }()
    
    zap.S().Infof("start received message...")

    // 消费消息
    for message := range claim.Messages() {
        zap.S().Infof("Message received: %s", string(message.Value))
    }
}