event

type Event interface {
	Topic() string
	Key() string
	Value() []byte
}

type Handler func(context.Context, Event) error

type Receiver interface {
	Receive(ctx context.Context, handler Handler) error
	Close() error
}

type Sender interface {
	Send(ctx context.Context, msg Event) error
	Close() error
}