feat: upgrade to Confluent.Kafka 2.4.0

BEagle1984 · Jun 5, 2024 · 8fe1ee7 · 8fe1ee7
1 parent 910dbc9
commit 8fe1ee7
Show file tree

Hide file tree

Showing 5 changed files with 27 additions and 4 deletions.
diff --git a/docs/releases.md b/docs/releases.md
@@ -9,6 +9,7 @@ uid: releases
 ### What's new
 
 * Upgrade to [MQTTnet 4.3.6.1152](https://github.com/chkr1011/MQTTnet/releases/tag/v4.3.6.1152)
+* Upgrade to [Confluent.Kafka 2.4.0](https://github.com/confluentinc/confluent-kafka-dotnet/releases/tag/v2.3.0)
 * Minor changes to reduce the likelihood of a deadlock
 
 ## [4.4.1](https://github.com/BEagle1984/silverback/releases/tag/v4.4.1)

diff --git a/...rback.Integration.Kafka.SchemaRegistry/Silverback.Integration.Kafka.SchemaRegistry.csproj b/...rback.Integration.Kafka.SchemaRegistry/Silverback.Integration.Kafka.SchemaRegistry.csproj
@@ -31,8 +31,8 @@ This package adds the support for Apache Avro and the schema registry on top of
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Confluent.Kafka" Version="2.3.0" />
-    <PackageReference Include="Confluent.SchemaRegistry.Serdes.Avro" Version="2.3.0" />
+    <PackageReference Include="Confluent.Kafka" Version="2.4.0" />
+    <PackageReference Include="Confluent.SchemaRegistry.Serdes.Avro" Version="2.4.0" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/...ilverback.Integration.Kafka/Messaging/Configuration/Kafka/ConfluentClientConfigProxies.cs b/...ilverback.Integration.Kafka/Messaging/Configuration/Kafka/ConfluentClientConfigProxies.cs
@@ -1008,6 +1008,28 @@ public string GroupProtocolType
             set => ConfluentConfig.GroupProtocolType = value;
         }
 
+        /// <summary>
+        ///     Group protocol type. NOTE: Currently, the only supported group protocol type is `consumer`.
+        ///     <br /><br />default: consumer
+        ///     <br />importance: low
+        /// </summary>
+        public GroupProtocol? GroupProtocol
+        {
+            get => ConfluentConfig.GroupProtocol;
+            set => ConfluentConfig.GroupProtocol = value;
+        }
+
+        /// <summary>
+        ///     Server side assignor to use. Keep it null to make server select a suitable assignor for the group. Available assignors: uniform or range. Default is null
+        ///     <br /><br />default: ''
+        ///     <br />importance: medium
+        /// </summary>
+        public string GroupRemoteAssignor
+        {
+            get => ConfluentConfig.GroupRemoteAssignor;
+            set => ConfluentConfig.GroupRemoteAssignor = value;
+        }
+
         /// <summary>
         ///     How often to query for the current client group coordinator. If the currently assigned coordinator is down the configured query interval will be divided by ten to more quickly recover in case of coordinator reassignment.
         ///     <br /><br />default: 600000

diff --git a/src/Silverback.Integration.Kafka/Silverback.Integration.Kafka.csproj b/src/Silverback.Integration.Kafka/Silverback.Integration.Kafka.csproj
@@ -31,7 +31,7 @@ This package contains an implementation of Silverback.Integration for the popula
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Confluent.Kafka" Version="2.3.0" />
+    <PackageReference Include="Confluent.Kafka" Version="2.4.0" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/...verback.Tools.KafkaConfigClassGenerator/Silverback.Tools.KafkaConfigClassGenerator.csproj b/...verback.Tools.KafkaConfigClassGenerator/Silverback.Tools.KafkaConfigClassGenerator.csproj
@@ -7,7 +7,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Confluent.Kafka" Version="2.3.0">
+    <PackageReference Include="Confluent.Kafka" Version="2.4.0">
       <!-- Workaround for xml documentation not being copied to output folder -->
       <CopyToOutputDirectory>lib/netcoreapp2.1/*.xml</CopyToOutputDirectory>
     </PackageReference>