在kafka-go中阅读带有特定ID的消息

import (
    "context"
    "fmt"
    "github.com/segmentio/kafka-go"
)

func main() {
    // Kafka集群地址
    brokers := []string{"kafka1:9092", "kafka2:9092"}

    // 创建一个消费者实例
    consumer := kafka.NewReader(kafka.ReaderConfig{
        Brokers: brokers,
        GroupID: "my-group",
    })

    // 订阅主题
    consumer.SubscribeTopics([]string{"my-topic"}, nil)

    // 定位到特定ID的消息
    consumer.Seek(kafka.SeekID(12345))

    // 读取消息
    msg, err := consumer.ReadMessage(context.Background())
    if err != nil {
        fmt.Printf("Error reading message: %v\n", err)
        return
    }

    // 处理消息
    fmt.Printf("Received message: %s\n", string(msg.Value))
    
    // 关闭消费者
    consumer.Close()
}