kafka

Documentation

Index

• type Producer
  • func NewProducerAdapter(producer kafka.IProducer) *Producer
  • func (p Producer) Output() chan kafka.BytesMessage

Types

type Producer

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

Producer exposes an output function, to satisfy the interface used by go-ns libraries

func NewProducerAdapter

func NewProducerAdapter(producer kafka.IProducer) *Producer

NewProducerAdapter creates a new kafka producer with access to Output function

func (Producer) Output

func (p Producer) Output() chan kafka.BytesMessage

Output returns the output channel