OAuth Azure IMDS Kafka example

[emasab]

What

Checklist

• Contains customer facing changes? Including API/behavior changes
• Did you add sufficient unit test and/or integration test coverage for this PR?
  • If not, please explain why it is not required

References

JIRA:

Test & Review

Open questions / Follow-ups

[Copilot]

Pull Request Overview

This PR adds support for OAuth Azure Instance Metadata Service (IMDS) authentication to the Confluent Kafka client library. It introduces a new metadata-based authentication type for OAUTHBEARER/OIDC that allows authentication using Azure IMDS endpoints with managed identities.

• Added new SaslOauthbearerMetadataAuthenticationType enum with AzureIMDS option
• Updated configuration generation to support the new Azure IMDS authentication type
• Added a complete example demonstrating OAuth OIDC authentication with Azure IMDS

Reviewed Changes

Copilot reviewed 5 out of 5 changed files in this pull request and generated 4 comments.

Show a summary per file

File	Description
src/Confluent.Kafka/Config_gen.cs	Auto-generated configuration file with new enum and property for Azure IMDS authentication
src/ConfigGen/Program.cs	Added mapping for azure_imds to AzureIMDS in configuration generation
examples/OAuthOIDCAzureIMDS/Program.cs	New example demonstrating OAuth OIDC authentication using Azure IMDS
examples/OAuthOIDCAzureIMDS/OAuthOIDCAzureIMDS.csproj	Project file for the new Azure IMDS example
CHANGELOG.md	Added changelog entry documenting the new OAuth OIDC Azure IMDS feature

---

_{Tip: Customize your code reviews with copilot-instructions.md. Create the file or learn how to get started.}

[Copilot]

Array index mismatch - the code checks for 2 arguments but accesses index 1 when the usage message suggests only one argument (brokerList). This should be args[0] if expecting one argument, or the argument count check should be updated.

Suggested change

	if (args.Length != 2)
	{
	Console.WriteLine("Usage: .. brokerList");
	return;
	}
	var bootstrapServers = args[1];
	if (args.Length != 1)
	{
	Console.WriteLine("Usage: .. brokerList");
	return;
	}
	var bootstrapServers = args[0];

[Copilot]

Use string instead of String - the lowercase alias is preferred in C# code.

Suggested change

	private static void createTopic(ClientConfig config, String topicName)
	private static void createTopic(ClientConfig config, string topicName)

[Copilot]

Double semicolon at the end of the line should be a single semicolon.

Suggested change

	new TopicSpecification { Name = topicName, ReplicationFactor = 3, NumPartitions = 1 } }).Wait(); ;
	new TopicSpecification { Name = topicName, ReplicationFactor = 3, NumPartitions = 1 } }).Wait();

[Copilot]

The NJsonSchema package reference appears unused in the example code. Consider removing this dependency if it's not needed.

Suggested change

	<ItemGroup>
	<PackageReference Include="NJsonSchema" Version="10.8.0" />
	</ItemGroup>
	<!-- Removed unused NJsonSchema package reference -->

[sonarqube-confluent]

• 66.70% Coverage on New Code (is less than 80.00%)

Analysis Details

0 Issues

• 0 Bugs
• 0 Vulnerabilities
• 0 Code Smells

Coverage and Duplications

• 66.70% Coverage (77.30% Estimated after merge)
• No duplication information (0.00% Estimated after merge)

Project ID: confluent-kafka-dotnet

View in SonarQube