feat: upgrade to Confluent.Kafka 2.1.0

src/Silverback.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.0.2" />
-    <PackageReference Include="Confluent.SchemaRegistry.Serdes.Avro" Version="2.0.2" />
+    <PackageReference Include="Confluent.Kafka" Version="2.1.0" />
+    <PackageReference Include="Confluent.SchemaRegistry.Serdes.Avro" Version="2.1.0" />
   </ItemGroup>
 
   <ItemGroup>

src/Silverback.Integration.Kafka.Testing/Messaging/Broker/Kafka/Mocks/MockedConfluentAdminClient.cs

@@ -25,6 +25,8 @@ public MockedConfluentAdminClient(ClientConfig config, IMockedKafkaOptions optio
 
         public Handle Handle { get; } = new();
 
+        public void SetSaslCredentials(string username, string password) => throw new NotSupportedException();
+
         public int AddBrokers(string brokers) => throw new NotSupportedException();
 
         public List<GroupInfo> ListGroups(TimeSpan timeout) => throw new NotSupportedException();

src/Silverback.Integration.Kafka.Testing/Messaging/Broker/Kafka/Mocks/MockedConfluentConsumer.cs

@@ -96,6 +96,8 @@ public MockedConfluentConsumer(
 
         internal Action<IConsumer<byte[]?, byte[]?>, CommittedOffsets>? OffsetsCommittedHandler { get; set; }
 
+        public void SetSaslCredentials(string username, string password) => throw new NotSupportedException();
+
         public int AddBrokers(string brokers) => throw new NotSupportedException();
 
         public ConsumeResult<byte[]?, byte[]?> Consume(int millisecondsTimeout) =>
@@ -258,6 +260,8 @@ public List<TopicPartitionOffset> Committed(
 
         public Offset Position(TopicPartition partition) => throw new NotSupportedException();
 
+        public TopicPartitionOffset PositionTopicPartitionOffset(TopicPartition partition) => throw new NotSupportedException();
+
         public List<TopicPartitionOffset> OffsetsForTimes(
             IEnumerable<TopicPartitionTimestamp> timestampsToSearch,
             TimeSpan timeout) =>

src/Silverback.Integration.Kafka.Testing/Messaging/Broker/Kafka/Mocks/MockedConfluentProducer.cs

@@ -46,6 +46,8 @@ public MockedConfluentProducer(
 
         internal Action<IProducer<byte[]?, byte[]?>, string>? StatisticsHandler { get; set; }
 
+        public void SetSaslCredentials(string username, string password) => throw new NotSupportedException();
+
         public int AddBrokers(string brokers) => throw new NotSupportedException();
 
         public Task<DeliveryResult<byte[]?, byte[]?>> ProduceAsync(

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.0.2" />
+    <PackageReference Include="Confluent.Kafka" Version="2.1.0" />
   </ItemGroup>
 
   <ItemGroup>

tools/Silverback.Tools.KafkaConfigClassGenerator/Silverback.Tools.KafkaConfigClassGenerator.csproj

@@ -7,7 +7,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Confluent.Kafka" Version="2.0.2">
+    <PackageReference Include="Confluent.Kafka" Version="2.1.0">
       <!-- Workaround for xml documentation not being copied to output folder -->
       <CopyToOutputDirectory>lib/netcoreapp2.1/*.xml</CopyToOutputDirectory>
     </PackageReference>