kafka

Documentation

Index

• func MarshalKafkaDataToStruct(data []byte, structToMarshal interface{}) error
• func NewReader(cfg kafka.ReaderConfig, log logger.Logger) *kafka.Reader
• func NewWriter(writer kafka.Writer, log logger.Logger) *kafka.Writer
• func UnmarshalToKafkaMessage(data []byte) (models.KafkaMessage, error)
• func WriteToTopicInBackground(ctx context.Context, writer *kafka.Writer, topic string, key string, ...) error
• type Reader
• type WriterConfig

Functions

func MarshalKafkaDataToStruct

func MarshalKafkaDataToStruct(data []byte, structToMarshal interface{}) error

func NewReader

func NewReader(cfg kafka.ReaderConfig, log logger.Logger) *kafka.Reader

func NewWriter

func NewWriter(writer kafka.Writer, log logger.Logger) *kafka.Writer

func UnmarshalToKafkaMessage

func UnmarshalToKafkaMessage(data []byte) (models.KafkaMessage, error)

func WriteToTopicInBackground

func WriteToTopicInBackground(
	ctx context.Context,
	writer *kafka.Writer,
	topic string,
	key string,
	value models.KafkaMessage,
	log logger.Logger,
) error

Types

type Reader

type Reader struct {
	// contains filtered or unexported fields
}

type WriterConfig

type WriterConfig struct {
	Logger logger.Logger
}