diff --git a/internal/workers/queueUpdater/queue_updater.go b/internal/workers/queueUpdater/queue_updater.go index 5b64866..a8329b0 100644 --- a/internal/workers/queueUpdater/queue_updater.go +++ b/internal/workers/queueUpdater/queue_updater.go @@ -219,7 +219,7 @@ func (wc *QueueUpdater) processMessages(ctx context.Context, message models.Kafk } default: - wc.logger.Error("incorrect message type", zap.Any("Type:", message.Type)) + wc.logger.Error("incorrect message type", zap.Any("Type:", message)) return nil } return nil