kafkaconfig

Documentation

Index

• type KafkaProducer
• type SaramaProducer
  • func NewSaramaProducer(producer sarama.SyncProducer) *SaramaProducer
  • func (p *SaramaProducer) SendMessage(topic string, message []byte) error

Types

type KafkaProducer

type KafkaProducer interface {
	SendMessage(topic string, message []byte) error
}

type SaramaProducer

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

SaramaProducer is a wrapper around sarama.SyncProducer that implements the KafkaProducer interface.

func NewSaramaProducer

func NewSaramaProducer(producer sarama.SyncProducer) *SaramaProducer

NewSaramaProducer creates a new SaramaProducer.

func (*SaramaProducer) SendMessage

func (p *SaramaProducer) SendMessage(topic string, message []byte) error

SendMessage sends a message to a specific Kafka topic.