kafka

Aug 19, 2022

Changes in this version

type KafkaReader

+ func (kr *KafkaReader) Read() ([]byte, error)

Jul 28, 2022

Changes in this version

+ type KafkaReader struct

+ func NewKafkaReader(config KafkaReaderConfig) (*KafkaReader, error)

+ func (kr *KafkaReader) Close() error

+ func (kr *KafkaReader) Write() ([]byte, error)

+ type KafkaReaderConfig struct

+ Brokers []string

+ GroupId string

+ MaxBytes int

+ MinBytes int

+ QueueCapacity int

+ Topic string

Jun 22, 2022

Changes in this version

+ type Message []byte

Jun 21, 2022

Changes in this version

+ type KafkaWritter struct

+ func (kw *KafkaWritter) Close() error

+ func (kw *KafkaWritter) Write(msg []byte)

Jun 21, 2022

Changes in this version

+ func NewKafkaWritter(config KafkaWritterConfig) (*kafkaWritter, error)

+ type KafkaWritterConfig struct

+ BatchSize int

+ BatchTimeout time.Duration

+ Brokers []string

+ LogFileName string

+ MaxAttempts int

+ Topic string

+ WriteTimeout time.Duration