kafka

type ConsumerGroup interface {
	Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error
	Errors() <-chan error
	Close() error
}

type ConsumerGroupCreator interface {
	Create(brokers []string, group string, cfg *sarama.Config) (ConsumerGroup, error)
}

type ConsumerGroupHandler struct {
	MaxMessageLen int
	TopicTag      string
	// contains filtered or unexported fields
}

type Input struct {
	Brokers                []string      `toml:"brokers"`
	ConsumerGroup          string        `toml:"consumer_group"`
	MaxMessageLen          int           `toml:"max_message_len"`
	MaxUndeliveredMessages int           `toml:"max_undelivered_messages"`
	MaxProcessingTime      time.Duration `toml:"max_processing_time"`
	Offset                 string        `toml:"offset"`
	BalanceStrategy        string        `toml:"balance_strategy"`
	Topics                 []string      `toml:"topics"`
	TopicTag               string        `toml:"topic_tag"`
	ConsumerFetchDefault   int64         `toml:"consumer_fetch_default"`
	ConnectionStrategy     string        `toml:"connection_strategy"`

	kafka.ReadConfig

	kafka.Logger
	Log logger.Logger `toml:"-"`

	ConsumerCreator ConsumerGroupCreator `toml:"-"`
	// contains filtered or unexported fields
}

type SaramaCreator struct{}