events

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

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

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

type KafkaManagerOptions struct {
	// yaml
	Host               string `mapstructure:"host"`
	ErrChanSize        int    `mapstructure:"err_chan_size"`
	ThrottleBottleSize int    `mapstructure:"throttle_bottle_size"`
	Producer           struct {
		RequiredACKs    int  `mapstructure:"required_acks"`
		MaxMessageBytes int  `mapstructure:"max_message_bytes"`
		Compression     int  `mapstructure:"compression"`
		FlushFrequency  int  `mapstructure:"flush_frequency"`
		ReturnSuccess   bool `mapstructure:"return_success"`
		ReturnErrors    bool `mapstructure:"return_errors"`
	} `mapstructure:"producer"`

	Consumer struct {
		GroupMode               int   `mapstructure:"group_mode"`
		GroupNotification       bool  `mapstructure:"group_notification"`
		OffsetInitial           int   `mapstructure:"offset_initial"`
		ReturnErrors            bool  `mapstructure:"return_errors"`
		BatchConsumptionSize    int   `mapstructure:"batch_consumption_size"`
		BatchConsumptionTimeout int64 `mapstructure:"batch_consumption_timeout"`
	} `mapstructure:"consumer"`
}