diff --git a/src/KafkaFlow.SchemaRegistry/KafkaFlow.SchemaRegistry.csproj b/src/KafkaFlow.SchemaRegistry/KafkaFlow.SchemaRegistry.csproj
index 39a84a012..b1241a6fb 100644
--- a/src/KafkaFlow.SchemaRegistry/KafkaFlow.SchemaRegistry.csproj
+++ b/src/KafkaFlow.SchemaRegistry/KafkaFlow.SchemaRegistry.csproj
@@ -8,7 +8,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Confluent.SchemaRegistry" Version="1.9.3" />
+        <PackageReference Include="Confluent.SchemaRegistry" Version="2.1.1" />
         <PackageReference Include="Microsoft.IO.RecyclableMemoryStream" Version="2.1.3" />
     </ItemGroup>
 
diff --git a/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro/KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro.csproj b/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro/KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro.csproj
index 81dbc0692..355666973 100644
--- a/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro/KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro.csproj
+++ b/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro/KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro.csproj
@@ -15,8 +15,8 @@
 
     <ItemGroup>
         <PackageReference Include="Apache.Avro" Version="1.11.0" />
-        <PackageReference Include="Confluent.Kafka" Version="1.9.3" />
-        <PackageReference Include="Confluent.SchemaRegistry" Version="1.9.3" />
+        <PackageReference Include="Confluent.Kafka" Version="2.1.1" />
+        <PackageReference Include="Confluent.SchemaRegistry" Version="2.1.1" />
         <PackageReference Include="Confluent.SchemaRegistry.Serdes.Avro" Version="1.9.3" />
     </ItemGroup>
 
diff --git a/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentJson/KafkaFlow.Serializer.SchemaRegistry.ConfluentJson.csproj b/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentJson/KafkaFlow.Serializer.SchemaRegistry.ConfluentJson.csproj
index 0b2ad6cfc..c7e599371 100644
--- a/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentJson/KafkaFlow.Serializer.SchemaRegistry.ConfluentJson.csproj
+++ b/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentJson/KafkaFlow.Serializer.SchemaRegistry.ConfluentJson.csproj
@@ -8,7 +8,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Confluent.SchemaRegistry" Version="1.9.3" />
+        <PackageReference Include="Confluent.SchemaRegistry" Version="2.1.1" />
         <PackageReference Include="Confluent.SchemaRegistry.Serdes.Json" Version="1.9.3" />
     </ItemGroup>
 
diff --git a/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf/KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf.csproj b/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf/KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf.csproj
index f5f602b06..f2eac2e3b 100644
--- a/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf/KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf.csproj
+++ b/src/KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf/KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf.csproj
@@ -8,8 +8,8 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Confluent.Kafka" Version="1.9.3" />
-        <PackageReference Include="Confluent.SchemaRegistry" Version="1.9.3" />
+        <PackageReference Include="Confluent.Kafka" Version="2.1.1" />
+        <PackageReference Include="Confluent.SchemaRegistry" Version="2.1.1" />
         <PackageReference Include="Confluent.SchemaRegistry.Serdes.Protobuf" Version="1.9.3" />
     </ItemGroup>
 
diff --git a/src/KafkaFlow/KafkaFlow.csproj b/src/KafkaFlow/KafkaFlow.csproj
index f1c934bd9..1aa6b346b 100644
--- a/src/KafkaFlow/KafkaFlow.csproj
+++ b/src/KafkaFlow/KafkaFlow.csproj
@@ -7,7 +7,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Confluent.Kafka" Version="1.9.3" />
+        <PackageReference Include="Confluent.Kafka" Version="2.1.1" />
         <PackageReference Include="System.Threading.Channels" Version="4.7.1" />
     </ItemGroup>