From 97f17f26d6e73017f2f2508b77a8f2a67deb9948 Mon Sep 17 00:00:00 2001
From: Kirill <kutuz.kirya.v.1.2.5@gmail.com>
Date: Fri, 7 Jul 2023 10:38:11 +0000
Subject: [PATCH] feat: details to init kafka topics log

---
 pkg/kafka/kafka.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pkg/kafka/kafka.go b/pkg/kafka/kafka.go
index 94e9555..1b4aac2 100644
--- a/pkg/kafka/kafka.go
+++ b/pkg/kafka/kafka.go
@@ -66,7 +66,7 @@ func Initialize(ctx context.Context, brokers, topics []string) error {
 	for _, topic := range topics {
 		isExist, err := kafka.TopicExists(ctx, topic)
 		if err != nil {
-			lastInitializeErr = fmt.Errorf("failed to check is topic <%s> exist on <Initialize> of <BrokerService>: %w", topic, err)
+			lastInitializeErr = fmt.Errorf("failed to check is topic <%s> exist on brokers <%+q>: %w", topic, brokers, err)
 			continue
 		}
 
@@ -75,7 +75,7 @@ func Initialize(ctx context.Context, brokers, topics []string) error {
 		}
 
 		if err := kafka.CreateTopic(ctx, topic); err != nil {
-			lastInitializeErr = fmt.Errorf("failed to create topic <%s> on <Initialize> of <BrokerService>: %w", topic, err)
+			lastInitializeErr = fmt.Errorf("failed to create topic <%s> on brokers <%+q>: %w", topic, brokers, err)
 		}
 	}