consumer debug

main.go

@@ -46,6 +46,7 @@ func main() {
 	noaaConsumer := consumer.New(trafficControllerURL, &tls.Config{
 		InsecureSkipVerify: conf.Nozzle.SkipSSL,
 	}, nil)
+	noaaConsumer.SetDebugPrinter(loggerDebugPrinter{})
 	events, errs := noaaConsumer.Firehose(strings.Trim(conf.Nozzle.FirehoseSubscriptionID, " "), token)
 
 	wavefront := nozzle.CreateEventHandler(conf.Wavefront)
@@ -57,3 +58,10 @@ func main() {
 		logger.Fatal("[ERROR] Error forwarding", err)
 	}
 }
+
+type loggerDebugPrinter struct {
+}
+
+func (loggerDebugPrinter) Print(title, body string) {
+	logger.Printf("[%s] %s", title, body)
+}

nozzle/nozzle.go

@@ -95,5 +95,5 @@ func (s *forwardingNozzle) handleEvent(envelope *events.Envelope) {
 
 func (s *forwardingNozzle) handleError(err error) {
 	logger.Printf("Error from firehose - %v", err)
-	logger.Fatal("Forcing restart")
+	// logger.Fatal("Forcing restart")
 }