kafka

Documentation

Index

• Variables
• type KafkaConsumer
  • func NewKafkaConsumer(name string) *KafkaConsumer
• type KafkaProducer
  • func NewKafkaProducer(name string) *KafkaProducer

Variables

var ConsumerConnectMap = make(map[string]*kafka.GroupConsumer)

var ProducerConnectMap = make(map[string]*kafka.Producer)

Types

type KafkaConsumer

type KafkaConsumer struct {
	*kafka.GroupConsumer
}

func NewKafkaConsumer

func NewKafkaConsumer(name string) *KafkaConsumer

type KafkaProducer

type KafkaProducer struct {
	*kafka.Producer
}

func NewKafkaProducer

func NewKafkaProducer(name string) *KafkaProducer