kafkaConsumer

Documentation

Index

• type Reader
  • func NewKafkaReader(cfg *ReaderConfig) *Reader
• type ReaderConfig

Types

type Reader

type Reader struct {
	Client *kafka.Reader
}

func NewKafkaReader

func NewKafkaReader(cfg *ReaderConfig) *Reader

type ReaderConfig

type ReaderConfig struct {
	Brokers []string
	GroupID string
	Topic   string
}