在Golang中使用Kafka进行消息确认，你需要使用一个支持消息确认的客户端库。一个流行的库是confluentinc/confluent-kafka-go。以下是一个简单的示例，展示了如何使用这个库进行消息确认：

首先，安装confluentinc/confluent-kafka-go库：

go get github.com/confluentinc/confluent-kafka-go/kafka

创建一个Kafka消费者，并设置消息确认处理函数：

package mainimport ("fmt""github.com/confluentinc/confluent-kafka-go/kafka")func main() {// 创建一个Kafka消费者配置conf := kafka.ConfigMap{"bootstrap.servers": "localhost:9092","group.id":"myGroup","auto.offset.reset": "earliest",}// 创建一个消费者实例c, err := kafka.NewConsumer(&conf)if err != nil {fmt.Printf("Failed to create consumer: %s\n", err)return}defer c.Close()// 订阅一个或多个主题err = c.SubscribeTopics([]string{"myTopic"}, nil)if err != nil {fmt.Printf("Failed to subscribe to topics: %s\n", err)return}// 处理消息确认的回调函数c.HandleAcks(kafka.AckAfterProcess)// 持续轮询并处理消息for {msg, err := c.ReadMessage(-1)if err != nil {fmt.Printf("Error reading message: %s\n", err)continue}// 处理消息fmt.Printf("Received message: key=%s, value=%s, topic=%s, partition=%d, offset=%d\n",string(msg.Key), string(msg.Value), msg.Topic, msg.Partition, msg.Offset)// 发送消息确认err = c.Ack(msg)if err != nil {fmt.Printf("Failed to acknowledge message: %s\n", err)}}}

在这个示例中，我们创建了一个Kafka消费者，订阅了一个名为myTopic的主题。我们设置了HandleAcks回调函数，以便在消息处理完成后发送确认。AckAfterProcess表示在消息处理完成后发送确认。

当消费者接收到一条消息时，它会打印消息的详细信息，然后调用Ack方法发送确认。如果确认发送成功，错误将为nil。如果发送失败，将打印错误信息。