diff --git a/consumer.go b/consumer.go index ae47b6d..7236ec7 100644 --- a/consumer.go +++ b/consumer.go @@ -99,8 +99,8 @@ func (c *BatchConsumer) StartConsumer() { signal.Notify(c.TerminateCh, syscall.SIGINT, syscall.SIGTERM) <-c.TerminateCh - cancel() + os.Exit(0) c.Workerline.Wait() }