kafka_listener

Documentation

Index

• type KafkaListener
  • func NewKafkaListener(brokers []string) *KafkaListener
  • func (kl *KafkaListener) Subscribe(topic string, callback func(message *sarama.ConsumerMessage)) error

Types

type KafkaListener

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

func NewKafkaListener

func NewKafkaListener(brokers []string) *KafkaListener

func (*KafkaListener) Subscribe

func (kl *KafkaListener) Subscribe(topic string, callback func(message *sarama.ConsumerMessage)) error