kafkaclient

Nov 26, 2024

Changes in this version

+ type Logger interface

+ Debugf func(format string, args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Infof func(format string, args ...interface{})

+ Warnf func(format string, args ...interface{})

+ type StdLogger struct

+ func (l *StdLogger) Debugf(format string, args ...interface{})

+ func (l *StdLogger) Errorf(format string, args ...interface{})

+ func (l *StdLogger) Infof(format string, args ...interface{})

+ func (l *StdLogger) Warnf(format string, args ...interface{})

Nov 25, 2024

Changes in this version

+ type KafkaClient struct

+ func NewKafkaClient(broker string, maxRetries int, retryInterval time.Duration, ...) (*KafkaClient, error)

+ func (kc *KafkaClient) Close() error

+ func (kc *KafkaClient) IsReady() bool

+ func (kc *KafkaClient) SendBatch(batch []*sarama.ProducerMessage, topic string) error

+ func (kc *KafkaClient) StartBatchSender(ringBuffer *kafkabuff.RingBuffer, batchSize int, interval time.Duration, ...)