event

type KafkaConfig struct {
	Enabled         bool   `toml:"enabled" json:"-" default:"false" mapstructure:"enabled"`
	BrokerAddresses string `toml:"broker" json:"-"  mapstructure:"broker"`
	User            string `toml:"user" json:"-" mapstructure:"user"`
	Password        string `toml:"password" json:"-" mapstructure:"password"`
	Version         string `toml:"version" json:"-" mapstructure:"version"`
	Topic           string `toml:"topic" json:"-" mapstructure:"topic"`
	MaxMessageByte  int    `toml:"maxMessageByte" json:"-" mapstructure:"maxMessageByte"`
	DisableTLS      bool   `toml:"disableTLS" json:"-" mapstructure:"disableTLS"`
	DisableSASL     bool   `toml:"disableSASL" json:"-" mapstructure:"disableSASL"`
	ClientID        string `toml:"clientID" json:"-" mapstructure:"clientID"`
}

type KafkaConsumerConfig struct {
	KafkaConfig
	ConsumerGroup string `toml:"consumerGroup" json:"-" mapstructure:"consumerGroup"`
	InitialOffset *int64 `toml:"initialOffset" json:"-" mapstructure:"initialOffset"`
}

type LogErrorFunc func(string, ...interface{})

type ProcessEventFunc func(interface{}) error

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