producing

Documentation

Index

• func NewKafkaMessageProducer(writerFactory KafkaWriterFactory) *kafkaMessageProducer
• func NewKafkaWriterFlyweightFactory(config kafka.WriterConfig) *kafkaWriterFlyweightFactory
• type KafkaWriter
• type KafkaWriterFactory
• type MessageProducer

Functions

func NewKafkaMessageProducer

func NewKafkaMessageProducer(writerFactory KafkaWriterFactory) *kafkaMessageProducer

func NewKafkaWriterFlyweightFactory

func NewKafkaWriterFlyweightFactory(config kafka.WriterConfig) *kafkaWriterFlyweightFactory

Types

type KafkaWriter

type KafkaWriter interface {
	WriteMessages(ctx context.Context, msgs ...kafka.Message) error
}

type KafkaWriterFactory

type KafkaWriterFactory interface {
	CreateWriterForTopic(topicName string) KafkaWriter
}

type MessageProducer

type MessageProducer interface {
	Produce(message *data.MessagePack) error
}