kafka

type Consumer struct{}

type Handler interface {
	Do(ctx context.Context, msg *sarama.ConsumerMessage) error
	SetNext(h Handler) Handler
	Run(ctx context.Context, msg *sarama.ConsumerMessage) error
}

type NullHandler struct {
	WorkerHandler
}

type Producer struct {
	Topic        string              `json:"topic"`
	SyncProducer sarama.SyncProducer `json:"map"`
}

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