Versions in this module Expand all Collapse all v0 v0.0.3 Dec 20, 2021 Changes in this version + func NewFileSource(path, readFrom string, parsers []parsers.Parser, ...) fileSource + func NewKafkaSource(config KafkaSourceConfig, parsers []parsers.Parser) kafkaSource + type FileSourceConfig struct + Path string + ReadFrom string + type KafkaSaslConfig struct + Password string + Username string + type KafkaSourceConfig struct + Brokers string + CommitInterval time.Duration + GroupID string + MaxBytes int + MinBytes int + SaslConfig *KafkaSaslConfig + StartFromBeginning bool + Timeout time.Duration + Tls bool + Topic string + type Source interface + AddProcessors func([]processors.StreamingProcessor) + Close func() + Run func(context.Context, *sync.WaitGroup)
Go to main page