从Sarama中的errors通道读取数据的正确方法是什么？

config := sarama.NewConfig()
// 设置Kafka集群的地址等配置信息

consumer, err := sarama.NewConsumer([]string{"kafka-broker1:9092", "kafka-broker2:9092"}, config)
if err != nil {
    // 错误处理
}

partitionConsumer, err := consumer.ConsumePartition("my-topic", 0, sarama.OffsetNewest)
if err != nil {
    // 错误处理
}

// 读取errors通道中的错误信息
go func() {
    for err := range partitionConsumer.Errors() {
        // 处理错误信息
        fmt.Println("Error:", err.Err)
    }
}()

// 在主线程中进行消费数据的逻辑处理
for message := range partitionConsumer.Messages() {
    // 处理收到的消息
    fmt.Println("Received message:", string(message.Value))
}

// 关闭消费者实例
consumer.Close()