diff --git a/src/Confluent.Kafka.Extensions.Diagnostics/Confluent.Kafka.Extensions.Diagnostics.csproj b/src/Confluent.Kafka.Extensions.Diagnostics/Confluent.Kafka.Extensions.Diagnostics.csproj
index 2ad4f7c..b833bf3 100644
--- a/src/Confluent.Kafka.Extensions.Diagnostics/Confluent.Kafka.Extensions.Diagnostics.csproj
+++ b/src/Confluent.Kafka.Extensions.Diagnostics/Confluent.Kafka.Extensions.Diagnostics.csproj
@@ -26,7 +26,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Confluent.Kafka" Version="[1.8.2, 3.0.0)"/>
+        <PackageReference Include="Confluent.Kafka" Version="[2.2.0, 3.0.0)"/>
         <PackageReference Include="GitVersion.MsBuild" Version="5.12.0">
             <PrivateAssets>all</PrivateAssets>
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
diff --git a/src/Confluent.Kafka.Extensions.Diagnostics/InstrumentedProducer.cs b/src/Confluent.Kafka.Extensions.Diagnostics/InstrumentedProducer.cs
index b835d96..11a287e 100644
--- a/src/Confluent.Kafka.Extensions.Diagnostics/InstrumentedProducer.cs
+++ b/src/Confluent.Kafka.Extensions.Diagnostics/InstrumentedProducer.cs
@@ -13,6 +13,11 @@ public InstrumentedProducer(IProducer<TKey, TValue> producer)
 
     public int AddBrokers(string brokers) => _producerImplementation.AddBrokers(brokers);
 
+    public void SetSaslCredentials(string username, string password)
+    {
+        _producerImplementation.SetSaslCredentials(username, password);
+    }
+
     public Handle Handle => _producerImplementation.Handle;
 
     public string Name => _producerImplementation.Name;
diff --git a/tests/Confluent.Kafka.Extensions.Diagnostics.Tests/Confluent.Kafka.Extensions.Diagnostics.Tests.csproj b/tests/Confluent.Kafka.Extensions.Diagnostics.Tests/Confluent.Kafka.Extensions.Diagnostics.Tests.csproj
index 8b11a71..1687f91 100644
--- a/tests/Confluent.Kafka.Extensions.Diagnostics.Tests/Confluent.Kafka.Extensions.Diagnostics.Tests.csproj
+++ b/tests/Confluent.Kafka.Extensions.Diagnostics.Tests/Confluent.Kafka.Extensions.Diagnostics.Tests.csproj
@@ -9,14 +9,14 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Confluent.Kafka" Version="2.0.2"/>
+        <PackageReference Include="Confluent.Kafka" Version="2.2.0"/>
         <PackageReference Include="FluentAssertions" Version="6.11.0"/>
-        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.6.0"/>
+        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.6.3"/>
         <PackageReference Include="Snapshooter.Xunit" Version="0.13.0"/>
         <PackageReference Include="TestEnvironment.Docker.Containers.Kafka" Version="2.1.4"/>
-        <PackageReference Include="xunit" Version="2.4.2"/>
+        <PackageReference Include="xunit" Version="2.5.0"/>
         <PackageReference Include="Xunit.Extensions.AssemblyFixture" Version="2.4.1"/>
-        <PackageReference Include="xunit.runner.visualstudio" Version="2.4.5">
+        <PackageReference Include="xunit.runner.visualstudio" Version="2.5.0">
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
             <PrivateAssets>all</PrivateAssets>
         </PackageReference>