consumer

type AlwaysFailDecoder struct{}

type Consumer[T any] struct {
	// contains filtered or unexported fields
}

type Header = kafka.Header

type HeaderDependantDecoder struct {
	// Name of header that we will check.
	HeaderName string
	// Header value to Decoder mapping.
	Decoders map[string]IDecoder
	// Will be used in case if message have no headers, or we have no corresponding mapping in Decoders map.
	DefaultDecoder IDecoder
}

type IDecoder interface {
	Decode(headers []Header, value []byte, dst any) error
}

type ILogger interface {
	WarnContext(ctx context.Context, msg string, attrs ...any)
	ErrorContext(ctx context.Context, msg string, attrs ...any)
}

type JSONDecoder struct{}

type Msg[T any] struct {
	Partition     int
	Offset        int64
	HighWaterMark int64
	Key           []byte
	Value         T
	Headers       []Header
	Time          time.Time
}

type OptOptionsSetter func(o *Options)

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

type ProtoJSONDecoder struct{}