kafkaHelper

Documentation

Index

• func NewKafkaProducer(brokerList []string, config *sarama.Config) kafkaProducer
• type KafkaConsumer
  • func NewKafkaConsumer(config *sarama.Config, brokerList []string, topic string, groupID string) (*KafkaConsumer, error)
  • func (k *KafkaConsumer) Close()
  • func (k *KafkaConsumer) Consume() error
  • func (k *KafkaConsumer) GetDataChannel() chan string

Functions

func NewKafkaProducer

func NewKafkaProducer(brokerList []string, config *sarama.Config) kafkaProducer

Types

type KafkaConsumer

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

func NewKafkaConsumer

func NewKafkaConsumer(config *sarama.Config, brokerList []string, topic string, groupID string) (*KafkaConsumer, error)

func (*KafkaConsumer) Close

func (k *KafkaConsumer) Close()

func (*KafkaConsumer) Consume

func (k *KafkaConsumer) Consume() error

func (*KafkaConsumer) GetDataChannel

func (k *KafkaConsumer) GetDataChannel() chan string