cleanup unused code and broken pidfile gen

main.go

@@ -25,15 +25,14 @@ func main() {
 
 	flag.Parse()
 	util.InitLogger(*logFile)
-	util.WritePid(*pidFile)
 
 	// catch termination signal
 	signals := make(chan os.Signal, 1)
-	signal.Notify(signals, os.Interrupt, syscall.SIGTERM, syscall.SIGINT)
-	signal.Notify(signals)
+	signal.Notify(signals, syscall.SIGTERM, syscall.SIGINT)
 	go func() {
 		<-signals
-		shutdown(0)
+		log.Println("Received exit signal, kthxbye.")
+		os.Exit(0)
 	}()
 
 	// Enable Prometheus Export
@@ -56,11 +55,3 @@ func main() {
 	defer kafkaConn.Close()
 	runKafkaListener()
 }
-
-func shutdown(exitcode int) {
-	kafkaConn.Close()
-	os.Remove("./consumer_dashboard.pid")
-	log.Println("Received exit signal, kthxbye.")
-	// return exit code
-	os.Exit(exitcode)
-}

options.go

@@ -4,8 +4,7 @@ import "flag"
 
 var (
 	// common options
-	logFile = flag.String("log", "", "Location of the log file.")
-	pidFile = flag.String("pid", "", "Location of the pid file.")
+	logFile = flag.String("log", "./consumer_dashboard.log", "Location of the log file.")
 
 	// Kafka options
 	kafkaConsumerGroup = flag.String("kafka.consumer_group", "dashboard", "Kafka Consumer Group")