kafka

Jul 13, 2024

Changes in this version

+ type Adapter struct

+ func NewAdapter() *Adapter

+ func (o *Adapter) GetBucket() *base.Bucket[*base.Item]

+ func (o *Adapter) GetFormatter() base.LoggerFormatter

+ func (o *Adapter) Log(item *base.Item)

+ func (o *Adapter) SetFormatter(formatter base.LoggerFormatter)

+ type Formatter struct

+ func (o *Formatter) Format(_ *base.Item) (body []byte)