Consumer

- remove feature `pause`

consumer/consumer.go

@@ -15,7 +15,6 @@ import (
 
 const (
 	flagSubscribed uint32 = iota
-	flagPaused
 )
 
 //goland:noinspection ALL
@@ -62,14 +61,6 @@ func (c *_consumer) Subscribed() bool {
 	return c.state.Contains(flagSubscribed)
 }
 
-func (c *_consumer) SetPause(f bool) {
-	if f {
-		c.state.Set(flagPaused)
-	} else {
-		c.state.Remove(flagPaused)
-	}
-}
-
 func (c *_consumer) RegisterHandlers(handlers ...service.ConsumerHandler) {
 	c.handlers = append(c.handlers, handlers...)
 }
@@ -84,7 +75,7 @@ func (c *_consumer) Subscribe(topics []string, ch chan *kafka.Message, opts serv
 	}
 
 	c.state.Set(flagSubscribed)
-	for c.Subscribed() && !c.state.Contains(flagPaused) {
+	for c.Subscribed() {
 		message, err := c.poll()
 		if err != nil {
 			// silently wait for a next message

kafka.go

@@ -28,7 +28,6 @@ type Consumer interface {
 	Subscribe([]string, chan *kafka.Message, ConsumerOptions) error
 	Subscribed() bool
 	RegisterHandlers(...ConsumerHandler)
-	SetPause(bool)
 }
 
 type Producer interface {