subscriber

type ConsumeFunc func(ctx context.Context, message event.EventString) error

type Subscriber interface {
	// Start the subscriber
	Start()
	// Close all underlying connections and resources
	Close() error
	// GroupID that is used
	GroupID() string
	// Topic that it is subscribed
	Topic() string
}