eventbus

type Conf struct {
	Brokers []string
}

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

type ConsumerHandlerI interface {
	Handle(b kafka.Message) bool
}

type ConsumerI interface {
	Consume(ctx context.Context)
}

type Model interface {
	ToMessage() kafka.Message
}

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

type ProducerI interface {
	Produce(ctx context.Context, m Model) error
}