diff --git a/pkg/wyze/producer.go b/pkg/wyze/producer.go
index af6c25f1..84a927ca 100644
--- a/pkg/wyze/producer.go
+++ b/pkg/wyze/producer.go
@@ -55,8 +55,6 @@ func NewProducer(rawURL string) (*Producer, error) {
 }
 
 func (p *Producer) Start() error {
-	defer p.client.Close()
-
 	for {
 		_ = p.client.SetDeadline(time.Now().Add(core.ConnDeadline))
 		pkt, err := p.client.ReadPacket()