Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions src/Confluent.Kafka/ClientExtensions.cs
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,9 @@ public static class ClientExtensions
/// <seealso cref="OAuthBearerSetTokenFailure"/>
public static void OAuthBearerSetToken(this IClient client, string tokenValue, long lifetimeMs, string principalName, IDictionary<string, string> extensions = null)
{
if (tokenValue == null) throw new System.ArgumentNullException(nameof(tokenValue));
if (principalName == null) throw new System.ArgumentNullException(nameof(principalName));

client.Handle.LibrdkafkaHandle.OAuthBearerSetToken(tokenValue, lifetimeMs, principalName, extensions);
}

Expand Down