kafka

Documentation

Index

• type Kafka
  • func New(kafka *pipeline.Kafka) (kaf *Kafka, err error)
  • func (s *Kafka) Close() error
  • func (s *Kafka) Send(msg *message2.Message) (ok bool, err error)

Types

type Kafka

type Kafka struct {
	Kafka        *pipeline.Kafka
	SyncProducer sarama.SyncProducer
}

Kafka send message to kafka

func New

func New(kafka *pipeline.Kafka) (kaf *Kafka, err error)

New returns a new Kafka

func (*Kafka) Close

func (s *Kafka) Close() error

func (*Kafka) Send

func (s *Kafka) Send(msg *message2.Message) (ok bool, err error)

Send Logic and control