Kafka semantics.
Go simplicity.

docker run -d --name liftbridge \
  -p 4222:4222 -p 9292:9292 \
  liftbridge/standalone-dev

mkdir liftbridge-demo && cd liftbridge-demo
go mod init demo
go get github.com/liftbridge-io/go-liftbridge/v2

package main

import (
    "context"
    "fmt"
    "log"

    lift "github.com/liftbridge-io/go-liftbridge/v2"
)

func main() {
    // Connect to Liftbridge
    client, err := lift.Connect([]string{"localhost:9292"})
    if err != nil {
        log.Fatal(err)
    }
    defer client.Close()

    ctx := context.Background()

    // Create a stream (maps NATS subject "events" to stream "events-stream")
    if err := client.CreateStream(ctx, "events", "events-stream"); err != nil {
        if err != lift.ErrStreamExists {
            log.Fatal(err)
        }
    }
    fmt.Println("Stream created!")

    // Publish a message
    if _, err := client.Publish(ctx, "events-stream",
        []byte("hello world")); err != nil {
        log.Fatal(err)
    }
    fmt.Println("Message published!")

    // Subscribe and read the message
    if err := client.Subscribe(ctx, "events-stream",
        func(msg *lift.Message, err error) {
            if err != nil {
                log.Fatal(err)
            }
            fmt.Printf("Received: %s\n", string(msg.Value()))
        },
        lift.StartAtEarliestReceived(),
    ); err != nil {
        log.Fatal(err)
    }
}

go run main.go