ikgo

Documentation

Index

• func BuildKgoOptions(cfg *config.Config, tp *sdktrace.TracerProvider, checker *health.Checker) []kgo.Opt
• type Producer
  • func NewProducer(client *kgo.Client) *Producer
  • func (p *Producer) Produce(ctx context.Context, rec *kgo.Record, promise func(*kgo.Record, error))
  • func (p *Producer) ProduceSync(ctx context.Context, rec *kgo.Record)

Functions

func BuildKgoOptions

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

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

Types

type Producer

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

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

func NewProducer

func NewProducer(client *kgo.Client) *Producer

NewProducer creates a new Producer.

func (*Producer) Produce

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 (*Producer) ProduceSync

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