Confluent 2.2

kmcclellan · Jul 21, 2023 · 4d10a33 · 4d10a33
1 parent 334c02d
commit 4d10a33
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 2 deletions.
diff --git a/Confluent.Kafka.DependencyInjection/Confluent.Kafka.DependencyInjection.csproj b/Confluent.Kafka.DependencyInjection/Confluent.Kafka.DependencyInjection.csproj
@@ -34,7 +34,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Confluent.Kafka" Version="[2.1.*,2.2.0)" />
+    <PackageReference Include="Confluent.Kafka" Version="*" />
     <PackageReference Include="Microsoft.Extensions.Configuration.Abstractions" Version="*" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="*" />
     <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="*" />

diff --git a/Confluent.Kafka.DependencyInjection/DependencyInjection/ScopedAdminClient.cs b/Confluent.Kafka.DependencyInjection/DependencyInjection/ScopedAdminClient.cs
@@ -27,6 +27,20 @@ public void SetSaslCredentials(string username, string password)
         this.inner.SetSaslCredentials(username, password);
     }
 
+    public Task<DescribeUserScramCredentialsResult> DescribeUserScramCredentialsAsync(
+        IEnumerable<string> users,
+        DescribeUserScramCredentialsOptions? options = null)
+    {
+        return this.inner.DescribeUserScramCredentialsAsync(users, options);
+    }
+
+    public Task AlterUserScramCredentialsAsync(
+        IEnumerable<UserScramCredentialAlteration> alterations,
+        AlterUserScramCredentialsOptions? options = null)
+    {
+        return this.inner.AlterUserScramCredentialsAsync(alterations, options);
+    }
+
     public Metadata GetMetadata(TimeSpan timeout)
     {
         return this.inner.GetMetadata(timeout);
@@ -124,6 +138,13 @@ public Task AlterConfigsAsync(
         return this.inner.AlterConfigsAsync(configs, options);
     }
 
+    public Task<List<IncrementalAlterConfigsResult>> IncrementalAlterConfigsAsync(
+        Dictionary<ConfigResource, List<ConfigEntry>> configs,
+        IncrementalAlterConfigsOptions? options = null)
+    {
+        return this.inner.IncrementalAlterConfigsAsync(configs, options);
+    }
+
     public Task<DescribeAclsResult> DescribeAclsAsync(
         AclBindingFilter aclBindingFilter,
         DescribeAclsOptions? options = null)

diff --git a/Example/Example.csproj b/Example/Example.csproj
@@ -12,7 +12,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Confluent.SchemaRegistry.Serdes.Json" Version="2.1.*" />
+    <PackageReference Include="Confluent.SchemaRegistry.Serdes.Json" Version="*" />
     <PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="*" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="*" />
   </ItemGroup>