我有这个代码：

s := grpc.NewServer()
pb.RegisterMessageServiceServer(s, &messageServer{})

我有这个错误：
无法使用“&messageServer{}”（type *messageServer），因为类型MessageServiceServer Type无法实现“MessageServiceServer”，因为它具有非导出的方法，并且在不同的包中定义
我的messageServer结构体看起来像：

type messageServer struct{}

func (s *messageServer) mustEmbedUnimplementedMessageServiceServer() {
    //TODO implement me
    panic("implement me")
}

func (s *messageServer) MustEmbedUnimplementedMessageServiceServer() {
    //TODO implement me
    panic("implement me")
}

func (s *messageServer) SendMessage(ctx context.Context, msg *pb.Message) (*pb.Response, error) {
    // Write the message to Kafka
    producer, err := sarama.NewSyncProducer([]string{kafkaBroker}, nil)
    if err != nil {
        log.Fatalf("Error creating Kafka producer: %v", err)
        return nil, err
    }
    defer producer.Close()

    kafkaMsg := &sarama.ProducerMessage{
        Topic: kafkaTopic,
        Value: sarama.StringEncoder(msg.Content),
    }

    _, _, err = producer.SendMessage(kafkaMsg)
    if err != nil {
        log.Printf("Failed to send message to Kafka: %v", err)
        return nil, err
    }

    return &pb.Response{Message: "Message sent to Kafka"}, nil
}

错误在这一行：

pb.RegisterMessageServiceServer(s, &messageServer{}) // here

不知道发生了什么事：（