storage

Documentation

Index

• type KafkaConsumer
  • func NewKafkaConsumer(brokers []string, topic, groupID string) *KafkaConsumer
  • func (kc *KafkaConsumer) Close() error
  • func (kc *KafkaConsumer) Consume(handler func(key, value []byte))

Types

type KafkaConsumer

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

KafkaConsumer represents a Kafka consumer

func NewKafkaConsumer

func NewKafkaConsumer(brokers []string, topic, groupID string) *KafkaConsumer

NewKafkaConsumer creates a new Kafka consumer

func (*KafkaConsumer) Close

func (kc *KafkaConsumer) Close() error

Close closes the Kafka consumer

func (*KafkaConsumer) Consume

func (kc *KafkaConsumer) Consume(handler func(key, value []byte))

Consume reads messages from the Kafka topic