kafka

type Config struct {
	Brokers []string
}

type ConfigDI interface {
	NewWriter(ctx context.Context, topic string) Writer
	NewReader(ctx context.Context, groupID, topic string, l log.Logger) Reader
}

type Reader interface {
	Read() ([]byte, error)
	Close() error
}

type Writer interface {
	Message(msg []byte) error
	Close() error
}