diff --git a/examples/Elastic.Extensions.Logging.Console.Example/Elastic.Extensions.Logging.Console.Example.csproj b/examples/Elastic.Extensions.Logging.Console.Example/Elastic.Extensions.Logging.Console.Example.csproj
index 05efcc92..4d730f65 100644
--- a/examples/Elastic.Extensions.Logging.Console.Example/Elastic.Extensions.Logging.Console.Example.csproj
+++ b/examples/Elastic.Extensions.Logging.Console.Example/Elastic.Extensions.Logging.Console.Example.csproj
@@ -2,7 +2,7 @@
 
     <PropertyGroup>
         <OutputType>Exe</OutputType>
-        <TargetFramework>net6.0</TargetFramework>
+        <TargetFramework>net8.0</TargetFramework>
         <ImplicitUsings>enable</ImplicitUsings>
         <Nullable>enable</Nullable>
     </PropertyGroup>
diff --git a/examples/Elastic.Extensions.Logging.Console.Example/Program.cs b/examples/Elastic.Extensions.Logging.Console.Example/Program.cs
index e1e08cd5..33f4c6eb 100644
--- a/examples/Elastic.Extensions.Logging.Console.Example/Program.cs
+++ b/examples/Elastic.Extensions.Logging.Console.Example/Program.cs
@@ -1,11 +1,12 @@
 // See https://aka.ms/new-console-template for more information
 
+using Elastic.CommonSchema;
 using Elastic.Extensions.Logging.Console;
 using Elastic.Extensions.Logging.Console.Example;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
+using Host = Microsoft.Extensions.Hosting.Host;
 
 await Host.CreateDefaultBuilder(args)
 	.UseConsoleLifetime()
@@ -13,7 +14,10 @@ await Host.CreateDefaultBuilder(args)
 	{
 		configurationBuilder.SetBasePath(AppDomain.CurrentDomain.BaseDirectory);
 	})
-	.ConfigureLogging((_, loggingBuilder) => loggingBuilder.AddEcsConsole())
+	.ConfigureLogging((_, loggingBuilder) => loggingBuilder.AddEcsConsole(configure: c =>
+	{
+		c.MapCustom = l => l.Organization = new Organization { Name = "my-organization" };
+	}))
 	.ConfigureServices((_, services) =>
 	{
 		services.AddHostedService<ExampleService>();
diff --git a/src/Elastic.Extensions.Logging.Common/ILogEventCreationOptions.cs b/src/Elastic.Extensions.Logging.Common/ILogEventCreationOptions.cs
index efca528b..40a24bfa 100644
--- a/src/Elastic.Extensions.Logging.Common/ILogEventCreationOptions.cs
+++ b/src/Elastic.Extensions.Logging.Common/ILogEventCreationOptions.cs
@@ -18,3 +18,13 @@ public interface ILogEventCreationOptions : IEcsDocumentCreationOptions
 	/// </summary>
 	string ListSeparator { get; set; }
 }
+
+/// <inheritdoc cref="ILogEventCreationOptions"/>
+public interface ILogEventCreationOptions<TEcsDocument> : ILogEventCreationOptions
+	where TEcsDocument : EcsDocument, new()
+{
+	/// <summary>
+	/// Allows you to enrich <typeparamref name="TEcsDocument"/> using <see cref="LogEvent"/> before its being formatted
+	/// </summary>
+	Action<TEcsDocument>? MapCustom { get; set; }
+}
diff --git a/src/Elastic.Extensions.Logging.Console/EcsConsoleFormatter.cs b/src/Elastic.Extensions.Logging.Console/EcsConsoleFormatter.cs
index e52fd5a5..420b0f43 100644
--- a/src/Elastic.Extensions.Logging.Console/EcsConsoleFormatter.cs
+++ b/src/Elastic.Extensions.Logging.Console/EcsConsoleFormatter.cs
@@ -34,10 +34,10 @@ public override void Write<TState>(in LogEntry<TState> logEntry, IExternalScopeP
 		var logLevel = logEntry.LogLevel;
 		var categoryName = logEntry.Category;
 		var eventId = logEntry.EventId;
+
+		logEvent.Message = message;
 		logEvent.Log = new Log { Level = logLevel.ToEcsLogLevelString(), Logger = categoryName };
 		logEvent.Event = new Event { Action = eventId.Name, Code = eventId.Id.ToString(), Severity = logLevel.ToEcsSeverity() };
-		logEvent.Message = message;
-
 		logEvent.Agent = DefaultAgent;
 
 		if (_options.Tags is { Length: > 0 }) logEvent.Tags = _options.Tags;
@@ -48,6 +48,8 @@ public override void Write<TState>(in LogEntry<TState> logEntry, IExternalScopeP
 		// These will overwrite any scope values with the same name
 		logEvent.AddStateValues(logEntry.State, _options);
 
+		_options.MapCustom?.Invoke(logEvent);
+
 		textWriter.WriteLine(logEvent.Serialize());
 	}
 
diff --git a/src/Elastic.Extensions.Logging.Console/EcsConsoleFormatterOptions.cs b/src/Elastic.Extensions.Logging.Console/EcsConsoleFormatterOptions.cs
index bb37508b..682c1b4e 100644
--- a/src/Elastic.Extensions.Logging.Console/EcsConsoleFormatterOptions.cs
+++ b/src/Elastic.Extensions.Logging.Console/EcsConsoleFormatterOptions.cs
@@ -6,7 +6,7 @@
 namespace Elastic.Extensions.Logging.Console;
 
 /// <summary>  </summary>
-public class EcsConsoleFormatterOptions : ConsoleFormatterOptions, ILogEventCreationOptions
+public class EcsConsoleFormatterOptions : ConsoleFormatterOptions, ILogEventCreationOptions<LogEvent>
 {
 	/// <inheritdoc cref="IEcsDocumentCreationOptions.IncludeHost"/>
 	public bool IncludeHost { get; set; } = true;
@@ -25,4 +25,7 @@ public class EcsConsoleFormatterOptions : ConsoleFormatterOptions, ILogEventCrea
 
 	/// <inheritdoc cref="ILogEventCreationOptions.ListSeparator"/>
 	public string ListSeparator { get; set; } = ", ";
+
+	/// <inheritdoc cref="ILogEventCreationOptions{TEcsDocument}.MapCustom"/>
+	public Action<LogEvent>? MapCustom { get; set; }
 }
diff --git a/src/Elastic.Extensions.Logging/ElasticsearchLogger.cs b/src/Elastic.Extensions.Logging/ElasticsearchLogger.cs
index 1e6290a4..30d1f8ff 100644
--- a/src/Elastic.Extensions.Logging/ElasticsearchLogger.cs
+++ b/src/Elastic.Extensions.Logging/ElasticsearchLogger.cs
@@ -99,6 +99,8 @@ Func<TState, Exception, string> formatter
 			// These will overwrite any scope values with the same name
 			logEvent.AddStateValues(state, _options);
 
+			_options.MapCustom?.Invoke(logEvent);
+
 			return logEvent;
 		}
 
diff --git a/src/Elastic.Extensions.Logging/Options/ElasticsearchLoggerOptions.cs b/src/Elastic.Extensions.Logging/Options/ElasticsearchLoggerOptions.cs
index 75737599..17d441df 100644
--- a/src/Elastic.Extensions.Logging/Options/ElasticsearchLoggerOptions.cs
+++ b/src/Elastic.Extensions.Logging/Options/ElasticsearchLoggerOptions.cs
@@ -1,3 +1,4 @@
+using System;
 using Elastic.CommonSchema;
 using Elastic.Extensions.Logging.Common;
 using Elastic.Ingest.Elasticsearch;
@@ -8,7 +9,7 @@ namespace Elastic.Extensions.Logging.Options
 	/// <summary>
 	/// Provide options to <see cref="ElasticsearchLogger"/> to control how data gets written to Elasticsearch
 	/// </summary>
-	public class ElasticsearchLoggerOptions : ILogEventCreationOptions
+	public class ElasticsearchLoggerOptions : ILogEventCreationOptions<LogEvent>
 	{
 		/// <summary>
 		/// Gets or sets a flag indicating whether host details should be included in the message. Defaults to <c>true</c>.
@@ -91,5 +92,8 @@ public class ElasticsearchLoggerOptions : ILogEventCreationOptions
 		/// <para>If set takes precedence over <see cref="ShipTo"/> </para>
 		/// </summary>
 		public ITransport? Transport { get; set; }
+
+		/// <inheritdoc cref="ILogEventCreationOptions{TEcsDocument}.MapCustom"/>
+		public Action<LogEvent>? MapCustom { get; set; }
 	}
 }