From e8fa90cd32d02cfd79ad7bb40552e322f46db668 Mon Sep 17 00:00:00 2001
From: Vadim Hatsura <vadim.hatsura@gmail.com>
Date: Thu, 27 Jul 2023 10:41:35 +0200
Subject: [PATCH] feat: bump up minimal supported version of Confluent.Kafka to
 2.2.0 (#27)

* Bump Microsoft.NET.Test.Sdk from 17.6.0 to 17.6.3

Bumps [Microsoft.NET.Test.Sdk](https://github.com/microsoft/vstest) from 17.6.0 to 17.6.3.
- [Release notes](https://github.com/microsoft/vstest/releases)
- [Changelog](https://github.com/microsoft/vstest/blob/main/docs/releases.md)
- [Commits](https://github.com/microsoft/vstest/compare/v17.6.0...v17.6.3)

---
updated-dependencies:
- dependency-name: Microsoft.NET.Test.Sdk
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>

* Bump xunit from 2.4.2 to 2.5.0

Bumps [xunit](https://github.com/xunit/xunit) from 2.4.2 to 2.5.0.
- [Commits](https://github.com/xunit/xunit/compare/2.4.2...2.5.0)

---
updated-dependencies:
- dependency-name: xunit
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

* Bump xunit.runner.visualstudio from 2.4.5 to 2.5.0

Bumps [xunit.runner.visualstudio](https://github.com/xunit/visualstudio.xunit) from 2.4.5 to 2.5.0.
- [Release notes](https://github.com/xunit/visualstudio.xunit/releases)
- [Commits](https://github.com/xunit/visualstudio.xunit/compare/v2.4.5...2.5.0)

---
updated-dependencies:
- dependency-name: xunit.runner.visualstudio
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

* Bump Confluent.Kafka from 2.0.2 to 2.2.0

Bumps [Confluent.Kafka](https://github.com/confluentinc/confluent-kafka-dotnet) from 2.0.2 to 2.2.0.
- [Release notes](https://github.com/confluentinc/confluent-kafka-dotnet/releases)
- [Changelog](https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/CHANGELOG.md)
- [Commits](https://github.com/confluentinc/confluent-kafka-dotnet/compare/v2.0.2...v2.2.0)

---
updated-dependencies:
- dependency-name: Confluent.Kafka
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

* chore: bump up minimal Confluent.Kafka version to 2.2.0

---------

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
---
 .../Confluent.Kafka.Extensions.Diagnostics.csproj         | 2 +-
 .../InstrumentedProducer.cs                               | 5 +++++
 .../Confluent.Kafka.Extensions.Diagnostics.Tests.csproj   | 8 ++++----
 3 files changed, 10 insertions(+), 5 deletions(-)

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>