chore: remove NewRelic dependency for vendor-neutral monitoring (#23)

OguzErdi · erdi.erkmen · web-flow · commit 7f29ab5c11c7 · 2026-02-06T10:22:03.000+03:00
- Remove NewRelic.Agent.Api package dependency
- Remove all NewRelic monitoring attributes from codebase
- Bump version to 1.7.0
- Update CHANGELOG and README with monitoring flexibility info
- Add .DS_Store to .gitignore

Co-authored-by: erdi.erkmen &lt;erdi.erkmen@trendyol.com&gt;
diff --git a/.gitignore b/.gitignore
@@ -268,3 +268,6 @@ __pycache__/
 
 #nCrunchTemp_
 
+# macOS system files
+.DS_Store
+
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,13 @@
+## v1.7.0 (February 5, 2026)
+
+### Removed:
+- NewRelic.Agent.Api dependency removed to make the project vendor-neutral
+- All NewRelic monitoring attributes ([Transaction], [Trace]) removed from codebase
+- This change makes the project more suitable for open-source use without proprietary dependencies
+
+### Changed:
+- Users can now integrate their own preferred monitoring solution (OpenTelemetry, Application Insights, Datadog, etc.)
+
 ## v1.6.0 (July 2, 2025)
 
 ### Added:
diff --git a/README.md b/README.md
@@ -122,6 +122,19 @@ The application uses circuit breakers to handle database operation failures grac
 The application can be configured using the `config.json` and `secret.json` files. Here are the configurations you can
 set:
 
+## Monitoring & Observability
+
+This project does not include built-in APM or monitoring. Users can integrate their preferred observability solution:
+- **OpenTelemetry** (vendor-neutral, recommended for distributed tracing)
+- **Application Insights** (Azure)
+- **Datadog**
+- **NewRelic**
+- **Elastic APM**
+- **Prometheus** (for metrics)
+- Or any other monitoring tool of your choice
+
+The codebase is clean and ready for you to add instrumentation as needed for your monitoring platform.
+
 ## Important Notes
 
 > [!WARNING]
diff --git a/src/Coordinators/MissingCoordinator/Services/MissingEventCleaner.cs b/src/Coordinators/MissingCoordinator/Services/MissingEventCleaner.cs
@@ -4,7 +4,6 @@
 using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.ConfigOptions;
 using PollingOutboxPublisher.Coordinators.MissingCoordinator.Services.Interfaces;
 using PollingOutboxPublisher.Database.Repositories.Interfaces;
@@ -31,7 +30,6 @@ public MissingEventCleaner(IOptions<WorkerSettings> workerSettings, ILogger<Miss
         _brokerErrorsMaxRetryCount = workerSettings.Value.BrokerErrorsMaxRetryCount;
     }
 
-    [Trace]
     public async Task CleanMissingEventsHaveOutboxEventAsync(MissingEvent[] missingEvents,
         List<MappedMissingEvent> results)
     {
@@ -46,13 +44,11 @@ public async Task CleanMissingEventsHaveOutboxEventAsync(MissingEvent[] missingE
         await PushToExceeded(missingEvents, _brokerErrorsMaxRetryCount);
     }
 
-    [Trace]
     public async Task CleanMissingEventsNotHaveOutboxEventAsync(MissingEvent[] missingEvents)
     {
         await PushToExceeded(missingEvents, _missingEventsMaxRetryCount);
     }
 
-    [Trace]
     public async Task HandleNonMatchedMissingEventsAsync(OutboxEvent[] outboxEvents,
         MissingEvent[] retryableMissingEvents)
     {
diff --git a/src/Coordinators/MissingCoordinator/Services/PollingMissingEventsQueue.cs b/src/Coordinators/MissingCoordinator/Services/PollingMissingEventsQueue.cs
@@ -1,9 +1,8 @@
-﻿using System.Collections.Generic;
+using System.Collections.Generic;
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.Extensions.Options;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.ConfigOptions;
 using PollingOutboxPublisher.Coordinators.MissingCoordinator.Services.Interfaces;
 using PollingOutboxPublisher.Models;
@@ -26,7 +25,6 @@ public PollingMissingEventsQueue(IPollingMissingEventsSource pollingMissingEvent
         _retryLimit = outboxSettings.Value.MissingEventsMaxRetryCount;
     }
 
-    [Trace]
     public Task<(MissingEvent[], MissingEvent[], List<MappedMissingEvent>, OutboxEvent[])> DequeueAsync(
         CancellationToken cancellationToken)
     {
diff --git a/src/Coordinators/MissingCoordinator/Services/PollingMissingEventsSource.cs b/src/Coordinators/MissingCoordinator/Services/PollingMissingEventsSource.cs
@@ -1,8 +1,7 @@
-﻿using System;
+using System;
 using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.Coordinators.MissingCoordinator.Services.Interfaces;
 using PollingOutboxPublisher.Database.Repositories.Interfaces;
 using PollingOutboxPublisher.Extensions;
@@ -25,7 +24,6 @@ public PollingMissingEventsSource(ILogger<PollingMissingEventsSource> logger,
         _outboxEventRepository = outboxEventRepository;
     }
 
-    [Trace]
     public async Task<MissingEvent[]> GetMissingEventsAsync(int batchCount)
     {
         var missingEvents = await _missingEventRepository.GetMissingEventsAsync(batchCount);
diff --git a/src/Coordinators/OutboxCoordinator/Services/OffsetSetter.cs b/src/Coordinators/OutboxCoordinator/Services/OffsetSetter.cs
@@ -3,7 +3,6 @@
 using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.Coordinators.OutboxCoordinator.Services.Interfaces;
 using PollingOutboxPublisher.Database.Repositories.Interfaces;
 using PollingOutboxPublisher.Models;
@@ -23,7 +22,6 @@ public OffsetSetter(ILogger<OffsetSetter> logger, IOutboxOffsetRepository outbox
         _outboxOffsetRepository = outboxOffsetRepository;
     }
 
-    [Trace]
     public async Task SetLatestOffset(OutboxEvent[] items)
     {
         try
diff --git a/src/Coordinators/OutboxCoordinator/Services/PollingOutboxQueue.cs b/src/Coordinators/OutboxCoordinator/Services/PollingOutboxQueue.cs
@@ -1,7 +1,6 @@
-﻿using System.Threading;
+using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.Extensions.Options;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.ConfigOptions;
 using PollingOutboxPublisher.Coordinators.OutboxCoordinator.Services.Interfaces;
 using PollingOutboxPublisher.Models;
@@ -23,7 +22,6 @@ public PollingOutboxQueue(IPollingSource pollingSource, IOptions<WorkerSettings>
         _prefetchCount = workerSettings.Value.OutboxEventsBatchSize;
     }
 
-    [Trace]
     public async Task<OutboxEvent[]> DequeueAsync(CancellationToken cancellationToken)
     {
         var result = await _pollingSource.GetNextAsync(_prefetchCount);
diff --git a/src/Coordinators/OutboxCoordinator/Services/PollingSource.cs b/src/Coordinators/OutboxCoordinator/Services/PollingSource.cs
@@ -1,6 +1,5 @@
-﻿using System.Threading.Tasks;
+using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.Coordinators.OutboxCoordinator.Services.Interfaces;
 using PollingOutboxPublisher.Database.Repositories.Interfaces;
 using PollingOutboxPublisher.Models;
@@ -22,7 +21,6 @@ public PollingSource(ILogger<PollingSource> logger, IOutboxOffsetRepository outb
         _outboxEventRepository = outboxEventRepository;
     }
 
-    [Trace]
     public async Task<OutboxEventsBatch> GetNextAsync(int batchCount)
     {
         var outboxEventsBatch = new OutboxEventsBatch();
diff --git a/src/Coordinators/Services/KafkaProducer.cs b/src/Coordinators/Services/KafkaProducer.cs
@@ -4,7 +4,6 @@
 using Confluent.Kafka;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.ConfigOptions;
 using PollingOutboxPublisher.Coordinators.Services.Interfaces;
 
@@ -61,14 +60,12 @@ private void BuildProducer(Kafka kafka)
         _producer = new ProducerBuilder<string, string>(config).Build();
     }
 
-    [Trace]
     public async Task<DeliveryResult<string, string>> ProduceAsync(string topic, Message<string, string> message)
     {
         var deliveryResult = await _producer.ProduceAsync(topic, message);
         return deliveryResult;
     }
 
-    [Trace]
     public void Dispose()
     {
         _producer?.Flush(TimeSpan.FromSeconds(10));
diff --git a/src/Coordinators/Services/KafkaService.cs b/src/Coordinators/Services/KafkaService.cs
@@ -1,7 +1,6 @@
 using System.Diagnostics.CodeAnalysis;
 using System.Threading.Tasks;
 using Confluent.Kafka;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.Coordinators.Services.Interfaces;
 
 namespace PollingOutboxPublisher.Coordinators.Services;
@@ -16,7 +15,6 @@ public KafkaService(IKafkaProducer kafkaProducer)
             _kafkaProducer = kafkaProducer;
         }
 
-    [Trace]
     public Task<DeliveryResult<string, string>> ProduceAsync(string topic, Message<string, string> message)
     {
             return _kafkaProducer.ProduceAsync(topic, message);
diff --git a/src/Coordinators/Services/OutboxDispatcher.cs b/src/Coordinators/Services/OutboxDispatcher.cs
@@ -1,8 +1,7 @@
-﻿using System;
+using System;
 using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.ConfigOptions;
 using PollingOutboxPublisher.Coordinators.Services.Interfaces;
 using PollingOutboxPublisher.Database.Repositories.Interfaces;
@@ -34,7 +33,6 @@ public OutboxDispatcher(ILogger<OutboxDispatcher> logger,
         _redeliveryDelayAfterError = workerSettings.Value.RedeliveryDelayAfterError;
     }
 
-    [Transaction]
     public async Task DispatchAsync(OutboxEvent outboxEvent)
     {
         try
@@ -49,7 +47,6 @@ await LogErrorAndHandle(ex, "Message broker is unavailable",
         }
     }
 
-    [Transaction]
     public async Task<MappedMissingEvent> DispatchMissingAsync(MappedMissingEvent mappedMissingEvent)
     {
         try
@@ -77,7 +74,6 @@ await LogErrorAndHandle(ex, "An error occurred",
         return mappedMissingEvent;
     }
 
-    [Trace]
     private async Task PublishAsync(OutboxEvent outboxEvent)
     {
         if (!_benchmarkOptions.Value.IsPublishingOn)
diff --git a/src/Database/Providers/CouchbaseScopeProvider.cs b/src/Database/Providers/CouchbaseScopeProvider.cs
@@ -1,9 +1,8 @@
-﻿using System.Diagnostics.CodeAnalysis;
+using System.Diagnostics.CodeAnalysis;
 using System.Threading.Tasks;
 using Couchbase;
 using Couchbase.KeyValue;
 using Microsoft.Extensions.Options;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.Database.Providers.Interfaces;
 using PollingOutboxPublisher.Exceptions;
 
@@ -20,7 +19,6 @@ public CouchbaseScopeProvider(IOptions<ConfigOptions.Couchbase> couchbaseOptions
         _couchbase = couchbaseOptions.Value;
     }
 
-    [Trace]
     public async Task<IScope> GetScopeAsync()
     {
         if (_scope != null) return _scope;
diff --git a/src/Database/Repositories/Couchbase/CouchbaseMissingEventRepository.cs b/src/Database/Repositories/Couchbase/CouchbaseMissingEventRepository.cs
@@ -6,7 +6,6 @@
 using Couchbase.KeyValue;
 using Couchbase.Query;
 using Microsoft.Extensions.Options;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.ConfigOptions;
 using PollingOutboxPublisher.Database.Providers.Interfaces;
 using PollingOutboxPublisher.Database.Repositories.Interfaces;
@@ -42,7 +41,6 @@ private async Task InitializeCollectionAsync()
         _collection ??= await _scope.CollectionAsync(_tableName);
     }
 
-    [Trace]
     public async Task InsertAsync(MissingEvent missingEvent)
     {
         await InitializeCollectionAsync();
diff --git a/src/Database/Repositories/MsSql/MsSqlMissingEventRepository.cs b/src/Database/Repositories/MsSql/MsSqlMissingEventRepository.cs
@@ -4,7 +4,6 @@
 using Dapper;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.ConfigOptions;
 using PollingOutboxPublisher.Database.Providers.Interfaces;
 using PollingOutboxPublisher.Database.Repositories.Interfaces;
@@ -30,7 +29,6 @@ public MsSqlMissingEventRepository(IMsSqlConnectionProvider msSqlConnectionProvi
                      throw new MissingConfigurationException(nameof(dataStoreSettings.Value.MissingEvents));
     }
 
-    [Trace]
     public async Task InsertAsync(MissingEvent missingEvent)
     {
         using var connection = _msSqlConnectionProvider.CreateConnection();
diff --git a/src/Database/Repositories/Postgres/PostgresMissingEventRepository.cs b/src/Database/Repositories/Postgres/PostgresMissingEventRepository.cs
@@ -4,7 +4,6 @@
 using Dapper;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using NewRelic.Api.Agent;
 using PollingOutboxPublisher.ConfigOptions;
 using PollingOutboxPublisher.Database.Providers.Interfaces;
 using PollingOutboxPublisher.Database.Repositories.Interfaces;
@@ -29,8 +28,7 @@ public PostgresMissingEventRepository(ILogger<PostgresMissingEventRepository> lo
                          throw new MissingConfigurationException(nameof(tableNameSettings.Value.MissingEvents));
         }
 
-        [Trace]
-        public async Task InsertAsync(MissingEvent missingEvent)
+    public async Task InsertAsync(MissingEvent missingEvent)
         {
             using var connection = _postgresConnectionProvider.CreateConnection();
             await connection.ExecuteAsync(InsertStatement(), missingEvent);
diff --git a/src/Helper/KafkaHelper.cs b/src/Helper/KafkaHelper.cs
@@ -3,7 +3,6 @@
 using System.Diagnostics.CodeAnalysis;
 using System.Text;
 using Confluent.Kafka;
-using NewRelic.Api.Agent;
 using Newtonsoft.Json;
 using PollingOutboxPublisher.Models;
 
@@ -12,7 +11,6 @@ namespace PollingOutboxPublisher.Helper;
 [ExcludeFromCodeCoverage]
 public static class KafkaHelper
 {
-    [Trace]
     public static KafkaMessageModel PrepareKafkaMessageModel(this OutboxEvent message, string topicName, string key)
     {
             var kafkaMessage = new Message<string, string>
@@ -33,7 +31,6 @@ public static KafkaMessageModel PrepareKafkaMessageModel(this OutboxEvent messag
             return response;
         }
         
-    [Trace]
     private static void SetHeader(Message<string, string> message, string messageHeader)
     {
             if (string.IsNullOrEmpty(messageHeader))
@@ -50,7 +47,6 @@ private static void SetHeader(Message<string, string> message, string messageHea
             }
         }
 
-    [Trace]
     private static void AddHeader(this Message<string, string> message, string key, string value)
     {
             var bytes = value == null
diff --git a/src/PollingOutboxPublisher.csproj b/src/PollingOutboxPublisher.csproj
@@ -4,7 +4,7 @@
         <OutputType>Exe</OutputType>
         <TargetFramework>net8.0</TargetFramework>
         <IsPackable>false</IsPackable>
-        <Version>1.6.0</Version>
+        <Version>1.7.0</Version>
         <RootNamespace>PollingOutboxPublisher</RootNamespace>
     </PropertyGroup>
 
@@ -14,7 +14,6 @@
         <PackageReference Include="Dapper" Version="2.1.35" />
         <PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.0" />
         <PackageReference Include="Microsoft.Extensions.Logging" Version="8.0.0" />
-        <PackageReference Include="NewRelic.Agent.Api" Version="10.25.1" />
         <PackageReference Include="Polly" Version="8.4.0" />
         <PackageReference Include="Polly.Contrib.WaitAndRetry" Version="1.1.1" />
         <PackageReference Include="Serilog.Extensions.Hosting" Version="8.0.0" />

Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,6 @@`
`4`	`4`	`using System.Threading.Tasks;`
`5`	`5`	`using Microsoft.Extensions.Logging;`
`6`	`6`	`using Microsoft.Extensions.Options;`
`7`		`-using NewRelic.Api.Agent;`
`8`	`7`	`using PollingOutboxPublisher.ConfigOptions;`
`9`	`8`	`using PollingOutboxPublisher.Coordinators.MissingCoordinator.Services.Interfaces;`
`10`	`9`	`using PollingOutboxPublisher.Database.Repositories.Interfaces;`
`@@ -31,7 +30,6 @@ public MissingEventCleaner(IOptions<WorkerSettings> workerSettings, ILogger<Miss`
`31`	`30`	`_brokerErrorsMaxRetryCount = workerSettings.Value.BrokerErrorsMaxRetryCount;`
`32`	`31`	`}`
`33`	`32`
`34`		`- [Trace]`
`35`	`33`	`public async Task CleanMissingEventsHaveOutboxEventAsync(MissingEvent[] missingEvents,`
`36`	`34`	`List<MappedMissingEvent> results)`
`37`	`35`	`{`
`@@ -46,13 +44,11 @@ public async Task CleanMissingEventsHaveOutboxEventAsync(MissingEvent[] missingE`
`46`	`44`	`await PushToExceeded(missingEvents, _brokerErrorsMaxRetryCount);`
`47`	`45`	`}`
`48`	`46`
`49`		`- [Trace]`
`50`	`47`	`public async Task CleanMissingEventsNotHaveOutboxEventAsync(MissingEvent[] missingEvents)`
`51`	`48`	`{`
`52`	`49`	`await PushToExceeded(missingEvents, _missingEventsMaxRetryCount);`
`53`	`50`	`}`
`54`	`51`
`55`		`- [Trace]`
`56`	`52`	`public async Task HandleNonMatchedMissingEventsAsync(OutboxEvent[] outboxEvents,`
`57`	`53`	`MissingEvent[] retryableMissingEvents)`
`58`	`54`	`{`
Original file line number	Diff line number	Diff line change
`@@ -3,7 +3,6 @@`
`3`	`3`	`using System.Linq;`
`4`	`4`	`using System.Threading.Tasks;`
`5`	`5`	`using Microsoft.Extensions.Logging;`
`6`		`-using NewRelic.Api.Agent;`
`7`	`6`	`using PollingOutboxPublisher.Coordinators.OutboxCoordinator.Services.Interfaces;`
`8`	`7`	`using PollingOutboxPublisher.Database.Repositories.Interfaces;`
`9`	`8`	`using PollingOutboxPublisher.Models;`
`@@ -23,7 +22,6 @@ public OffsetSetter(ILogger<OffsetSetter> logger, IOutboxOffsetRepository outbox`
`23`	`22`	`_outboxOffsetRepository = outboxOffsetRepository;`
`24`	`23`	`}`
`25`	`24`
`26`		`- [Trace]`
`27`	`25`	`public async Task SetLatestOffset(OutboxEvent[] items)`
`28`	`26`	`{`
`29`	`27`	`try`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,5 @@`
`1`		`-using System.Threading.Tasks;`
	`1`	`+using System.Threading.Tasks;`
`2`	`2`	`using Microsoft.Extensions.Logging;`
`3`		`-using NewRelic.Api.Agent;`
`4`	`3`	`using PollingOutboxPublisher.Coordinators.OutboxCoordinator.Services.Interfaces;`
`5`	`4`	`using PollingOutboxPublisher.Database.Repositories.Interfaces;`
`6`	`5`	`using PollingOutboxPublisher.Models;`
`@@ -22,7 +21,6 @@ public PollingSource(ILogger<PollingSource> logger, IOutboxOffsetRepository outb`
`22`	`21`	`_outboxEventRepository = outboxEventRepository;`
`23`	`22`	`}`
`24`	`23`
`25`		`- [Trace]`
`26`	`24`	`public async Task<OutboxEventsBatch> GetNextAsync(int batchCount)`
`27`	`25`	`{`
`28`	`26`	`var outboxEventsBatch = new OutboxEventsBatch();`
Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,6 @@`
`4`	`4`	`using Confluent.Kafka;`
`5`	`5`	`using Microsoft.Extensions.Logging;`
`6`	`6`	`using Microsoft.Extensions.Options;`
`7`		`-using NewRelic.Api.Agent;`
`8`	`7`	`using PollingOutboxPublisher.ConfigOptions;`
`9`	`8`	`using PollingOutboxPublisher.Coordinators.Services.Interfaces;`
`10`	`9`
`@@ -61,14 +60,12 @@ private void BuildProducer(Kafka kafka)`
`61`	`60`	`_producer = new ProducerBuilder<string, string>(config).Build();`
`62`	`61`	`}`
`63`	`62`
`64`		`- [Trace]`
`65`	`63`	`public async Task<DeliveryResult<string, string>> ProduceAsync(string topic, Message<string, string> message)`
`66`	`64`	`{`
`67`	`65`	`var deliveryResult = await _producer.ProduceAsync(topic, message);`
`68`	`66`	`return deliveryResult;`
`69`	`67`	`}`
`70`	`68`
`71`		`- [Trace]`
`72`	`69`	`public void Dispose()`
`73`	`70`	`{`
`74`	`71`	`_producer?.Flush(TimeSpan.FromSeconds(10));`