kafka

Documentation

Index

• func NewReader(cfg kafka.ReaderConfig, log logger.Logger) *kafka.Reader
• func NewWriter(writer kafka.Writer, log logger.Logger) *kafka.Writer
• func WriteToTopicInBackground(ctx context.Context, writer *kafka.Writer, topic string, key string, ...) error
• type Reader
• type WriterConfig

Functions

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 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
}