ikgo

package

v0.1.3 Latest Latest Go to latest Published: Jan 29, 2026 License: BSD-3-Clause Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

func BuildKgoOptions(cfg *config.Config, tp *sdktrace.TracerProvider, checker *health.Checker) []kgo.Opt

BuildKgoOptions builds the options for the franz-go Kafka client.

type Producer struct {
	// contains filtered or unexported fields
}

Producer wraps a kgo.Client to provide a simple interface for producing messages.

func NewProducer(client *kgo.Client) *Producer

NewProducer creates a new Producer.

func (p *Producer) Produce(ctx context.Context, rec *kgo.Record, promise func(*kgo.Record, error))

Produce produces a single record to the given topic and returns.

func (p *Producer) ProduceSync(ctx context.Context, rec *kgo.Record)