How can I get the latest message in a topic?

[cocoza4]

No description provided.

[petedannemann]

// make a new reader that consumes from topic-A, partition 0, at offset 42
r := kafka.NewReader(kafka.ReaderConfig{
    Brokers:   []string{"localhost:9092","localhost:9093", "localhost:9094"},
    Topic:     "topic-A",
    Partition: 0,
    MaxBytes:  10e6, // 10MB
})
r.SetOffset(kafka.LastOffset)

m, err := r.ReadMessage(context.Background())
if err != nil {
    log.Fatal("failed to read latest message:", err)
}

[cocoza4]

thank you