Versions in this module Expand all Collapse all v0 v0.3.0 Dec 31, 2020 Changes in this version type KafkaSource + GroupId string v0.2.0 Nov 13, 2020 Changes in this version + type Consumer interface + ConsumeMessages func() error + type ElasticSearchTarget struct + Server string + type KafkaSource struct + Brokers []string + Offset int64 + Reader *kafka.Reader + Topic string + func (source *KafkaSource) CreateConnection() error + type PrinterConsumer struct + ConsumerName string + Debug bool + Source KafkaSource + WorkerCount int + func (s *PrinterConsumer) ConsumeMessages() error + type ProductionConsumer struct + BulkSize int + Debug bool + Source KafkaSource + Target ElasticSearchTarget + WorkerCount int + func (s *ProductionConsumer) ConsumeMessages() error
Go to main page