StreamBus Go SDK

Build High-Performance Streaming Applications

A modern, lightweight Go client library for StreamBus with enterprise-grade features

Get Started View on GitHub

Why StreamBus SDK?

StreamBus SDK is designed to make building distributed streaming applications in Go simple, efficient, and reliable.

🚀 High Performance

Achieve 1M+ messages/sec with minimal latency and resource usage

🔒 Enterprise Security

Built-in support for TLS/mTLS and SASL authentication

⚡ Zero Dependencies

Minimal external dependencies for maximum reliability

🎯 Simple API

Intuitive Go-idiomatic API that's easy to learn and use

Quick Example

package main

import (
    "log"
    "github.com/gstreamio/streambus-sdk/client"
)

func main() {
    // Connect to StreamBus
    config := client.DefaultConfig()
    config.Brokers = []string{"localhost:9092"}

    c, err := client.New(config)
    if err != nil {
        log.Fatal(err)
    }
    defer c.Close()

    // Send a message
    producer := client.NewProducer(c)
    err = producer.Send("events", []byte("key"), []byte("Hello StreamBus!"))
    if err != nil {
        log.Fatal(err)
    }

    log.Println("Message sent successfully!")
}