PenaSide/customer
3
0
Fork 0
generated from PenaSide/GolangTemplate
Code Issues 1 Pull Requests 2 Actions Packages Projects Releases Wiki Activity

feat: log info init topics

Browse Source
This commit is contained in:
Kirill 2023-07-07 10:09:50 +00:00
parent f349471fa4
commit ab373b6b8d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/kafka/kafka.go
View File

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