consumer

Documentation

Index

• type Consumer
• type ElasticSearchTarget
• type KafkaSource
  • func (source *KafkaSource) CreateConnection() error
• type PrinterConsumer
  • func (s *PrinterConsumer) ConsumeMessages() error
• type ProductionConsumer
  • func (s *ProductionConsumer) ConsumeMessages() error

Types

type Consumer

type Consumer interface {
	ConsumeMessages() error
}

type ElasticSearchTarget

type ElasticSearchTarget struct {
	Server string
}

type KafkaSource

type KafkaSource struct {
	Brokers []string
	Topic   string
	Offset  int64
	GroupId string

	Reader *kafka.Reader
}

func (*KafkaSource) CreateConnection

func (source *KafkaSource) CreateConnection() error

type PrinterConsumer

type PrinterConsumer struct {
	Source       KafkaSource
	WorkerCount  int
	ConsumerName string
	Debug        bool
}

func (*PrinterConsumer) ConsumeMessages

func (s *PrinterConsumer) ConsumeMessages() error

type ProductionConsumer

type ProductionConsumer struct {
	Source      KafkaSource
	Target      ElasticSearchTarget
	WorkerCount int
	BulkSize    int
	Debug       bool
}

func (*ProductionConsumer) ConsumeMessages

func (s *ProductionConsumer) ConsumeMessages() error