Versions in this module Expand all Collapse all v1 v1.0.0 Jan 19, 2024 Changes in this version + type CommonKafka interface + Close func() + GetKafkaWriter func() Writer + SetLog func(Logger) + func NewCommonKafka(ctx context.Context, di ConfigDI, topic string) CommonKafka + type ConfigDI interface + NewKafkaReader func(ctx context.Context, groupID, topic string) Reader + NewKafkaWriter func(ctx context.Context, topic string) Writer + type KafkaConfig struct + Brokers []string + func (c *KafkaConfig) NewKafkaReader(ctx context.Context, groupID, topic string) Reader + func (c *KafkaConfig) NewKafkaWriter(ctx context.Context, topic string) Writer + type Logger interface + Debug func(string) + Info func(string) + type Reader interface + Close func() error + Read func() (map[string]string, []byte, error) + ReadHandler func(handler ReaderHandler) error + type ReaderHandler func(headers map[string]string, data []byte) error + type Writer interface + Close func() error + Message func(headers map[string][]byte, msg []byte) error + SetLog func(Logger)
Go to main page