From 3a4d5f67967103c6c6d55aa5e8c4c7d31ad8d625 Mon Sep 17 00:00:00 2001
From: Alexander Zavorotynskiy <alexander@openreplay.com>
Date: Tue, 31 May 2022 14:43:56 +0200
Subject: [PATCH] feat(backend/sink): added additional log on producer write
 operation

---
 backend/internal/assetscache/assets.go | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/backend/internal/assetscache/assets.go b/backend/internal/assetscache/assets.go
index cf76bed8c..97d3eddb9 100644
--- a/backend/internal/assetscache/assets.go
+++ b/backend/internal/assetscache/assets.go
@@ -1,6 +1,7 @@
 package assetscache
 
 import (
+	"log"
 	"openreplay/backend/internal/config/sink"
 	"openreplay/backend/pkg/messages"
 	"openreplay/backend/pkg/queue/types"
@@ -54,9 +55,13 @@ func (e *AssetsCache) ParseAssets(sessID uint64, msg messages.Message) messages.
 
 func (e *AssetsCache) sendAssetForCache(sessionID uint64, baseURL string, relativeURL string) {
 	if fullURL, cacheable := assets.GetFullCachableURL(baseURL, relativeURL); cacheable {
-		e.producer.Produce(e.cfg.TopicCache, sessionID, messages.Encode(&messages.AssetCache{
-			URL: fullURL,
-		}))
+		if err := e.producer.Produce(
+			e.cfg.TopicCache,
+			sessionID,
+			messages.Encode(&messages.AssetCache{URL: fullURL}),
+		); err != nil {
+			log.Printf("can't send asset to cache topic, sessID: %d, err: %s", sessionID, err)
+		}
 	}
 }