From a11ca1da6e5bbc9809f19ca889614642e96cfa5f Mon Sep 17 00:00:00 2001
From: Alexey Khit <alexey.khit@gmail.com>
Date: Tue, 13 Sep 2022 14:40:58 +0300
Subject: [PATCH] Adds error output to producer start function

---
 cmd/streams/producer.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/cmd/streams/producer.go b/cmd/streams/producer.go
index 38283d27..f2655323 100644
--- a/cmd/streams/producer.go
+++ b/cmd/streams/producer.go
@@ -79,7 +79,11 @@ func (p *Producer) start() {
 	log.Debug().Str("url", p.url).Msg("[streams] start producer")
 
 	p.state = stateStart
-	go p.element.Start()
+	go func() {
+		if err := p.element.Start(); err != nil {
+			log.Warn().Err(err).Str("url", p.url).Msg("[streams] start")
+		}
+	}()
 }
 
 func (p *Producer) stop() {