kafka

Dec 4, 2022

Changes in this version

type Params

+ LogLevel log.LogLevel

Sep 6, 2022

Changes in this version

type Params

+ TestMessageTopic string

May 20, 2022

Changes in this version

+ func Initialize(p Params) *buffer

+ type KafkaWriter interface

+ WriteMessages func(ctx context.Context, msgs ...gokafka.Message) error

+ type Message struct

+ Content []byte

+ Topic string

+ type MessageChan chan Message

+ type Params struct

+ BatchSize int

+ Broker string

+ Channel MessageChan

+ Interval time.Duration

+ MaxBatchSize int

+ ObsChannel observability.Channel

+ Port int

+ RetryInterval time.Duration

+ Topic string

May 18, 2021

Changes in this version

type KafkaMessage

+ func (msg KafkaMessage) String() string

type KafkaParams

+ RetryInterval time.Duration

May 9, 2021

Changes in this version

+ func Run(ctx context.Context, params KafkaParams, id int)

+ type KafkaMessage struct

+ Content []byte

+ Topic string

+ type KafkaParams struct

+ Broker string

+ Channel MessageChannel

+ ObsChannel observability.ObservabilityChannel

+ Port int

+ Topic string

+ WaitGroup *sync.WaitGroup

+ type MessageChannel chan KafkaMessage