Versions in this module Expand all Collapse all v0 v0.2.0 Aug 28, 2026 Changes in this version type Config + Concurrency int + PartitionQueueSize int + type DLQConfig struct + Brokers []string + Extra []kgo.Opt + Source string + Topic string + type DLQProducer struct + func NewDLQProducer(cfg DLQConfig) (*DLQProducer, error) + func (d *DLQProducer) Close(ctx context.Context) error + func (d *DLQProducer) OnDecodeError(raw []byte, partition int32, offset int64, err error) + func (d *DLQProducer) OnFetchError(topic string, partition int32, err error) v0.1.0 May 12, 2026 Changes in this version + type Config struct + Brokers []string + ConsumerGroup string + Decode Decoder[T] + EventID func(T) string + Extra []kgo.Opt + OnDecodeError func(raw []byte, partition int32, offset int64, err error) + OnFetchError func(topic string, partition int32, err error) + Topic string + type Decoder func([]byte) (T, error) + func JSONDecoder[T any]() Decoder[T] + type Source struct + func NewSource[T any](cfg Config[T]) (*Source[T], error) + func (s *Source[T]) Close() error + func (s *Source[T]) Name() string + func (s *Source[T]) Read(ctx context.Context, out chan<- source.Record[T]) error
Go to main page