diff --git a/go.mod b/go.mod index 5aac2a4..7af0253 100644 --- a/go.mod +++ b/go.mod @@ -5,7 +5,6 @@ go 1.18 require ( github.com/Shopify/sarama v1.33.0 github.com/Songmu/prompter v0.5.0 - github.com/dustin/go-humanize v1.0.0 github.com/jedib0t/go-pretty/v6 v6.3.1 github.com/liggitt/tabwriter v0.0.0-20181228230101-89fcab3d43de github.com/manifoldco/promptui v0.9.0 diff --git a/go.sum b/go.sum index 25022bc..e7077f4 100644 --- a/go.sum +++ b/go.sum @@ -17,8 +17,6 @@ github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ3 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/dustin/go-humanize v1.0.0 h1:VSnTsYCnlFHaM2/igO1h6X3HA71jcobQuxemgkq4zYo= -github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk= github.com/eapache/go-resiliency v1.2.0 h1:v7g92e/KSN71Rq7vSThKaWIq68fL4YHvWyiUKorFR1Q= github.com/eapache/go-resiliency v1.2.0/go.mod h1:kFI+JgMyC7bLPUVY133qvEBtVayf5mFgVsvEsIPBvNs= github.com/eapache/go-xerial-snappy v0.0.0-20180814174437-776d5712da21 h1:YEetp8/yCZMuEPMUDHG0CW/brkkEp8mzqk2+ODEitlw= diff --git a/internal/pkg/kafka/console_consumer.go b/internal/pkg/kafka/console_consumer.go index b5080e6..a5ca60d 100644 --- a/internal/pkg/kafka/console_consumer.go +++ b/internal/pkg/kafka/console_consumer.go @@ -51,14 +51,10 @@ func ConsumeMessage(conn *KafkaConnection, topic string, group string, verbose b <-consumer.ready log.Println("Consumer running, waiting for events...") - sigusr1 := make(chan os.Signal, 1) - signal.Notify(sigusr1, syscall.SIGUSR1) - sigterm := make(chan os.Signal, 1) signal.Notify(sigterm, syscall.SIGINT, syscall.SIGTERM) defer signal.Stop(sigterm) - defer signal.Stop(sigusr1) for keepRunning { select {