[dependabot]

Updated Confluent.Kafka from 2.14.0 to 2.16.0.

Release notes

Sourced from Confluent.Kafka's releases.

2.16.0

New experimental features

• Serializers and deserializers can now be supplied to a producer, dependent
  producer or consumer as a builder, which the client invokes during its own
  construction and then owns, disposing it (and any Schema Registry client it
  created) when the client itself is disposed. See the AvroGeneric example (#​2661)
• Schema Registry serde builders are now available for each supported format,
  each configurable with a Schema Registry client you own or the
  configuration to build one from. See the AvroGeneric,
  JsonSerialization and Protobuf examples (#​2661)
• Producers, consumers and admin clients can now report the id of the Kafka
  cluster they're connected to (#​2661)
• The Kafka cluster id is now propagated to Schema Registry serializers and
  deserializers automatically, and resolved lazily on first use, so subject
  name strategies based on the cluster no longer need it configured by hand.
  See the AvroGenericAssociation example (#​2661)
• The serializer and deserializer builder APIs (Set*SerializerBuilder and
  Set*DeserializerBuilder on the producer and consumer builders, the Schema
  Registry serde builders), IClusterIdAware, ISerdeDisposable, SerdeExtensions
  and the ClusterId client extension are experimental: they are subject to
  change or removal in a future release (#​2661)

Enhancements

• References librdkafka.redist 2.16.0. Refer to the librdkafka v2.16.0 release notes for more information
• Add support for saving Azure key version with DEK (#​2641)
• Pass context when clients make KEK calls to DEK Registry (#​2642)
• Add support for inline validation rules (#​2651)
• Add Variant, Decimal, and Timestamp CEL functions (#​2653)
• Add support for linux-s390x (IBM Z), with CI coverage on s390x (#​2646)
• Schema Registry examples now use the serde builder API (#​2661)

Fixes

• Fix the CSFLE ciphertext version field being written little-endian on big-endian
  platforms, which made encrypted fields unreadable across architectures
• Fix message Timestamp.Type being read as NotAvailable on big-endian platforms
  (e.g. s390x): librdkafka's rd_kafka_timestamp_type_t out-parameter (a 32-bit enum)
  was marshalled as a pointer-sized IntPtr, so the value landed in the high word and
  was truncated to 0 on big-endian

2.15.1

Enhancements

• References librdkafka.redist 2.15.1. Refer to the librdkafka v2.15.1 release notes for more information.

Fixes

• Fix early return in FindMessageByName (#​2644)
• Preserve HTTP status for retriable SR errors (#​2647)
• Security patch in examples and tests using old NJsonSchema versions, test framework upgrade in Confluent.Kafka tests (#​2656)

2.15.0

Upgrade considerations

Ensure you're not calling StoreOffset with an EOF message.
As when calling Commit with an EOF message, it will throw an InvalidOperationException.
Previously this could cause skipping an offset (<2.1.0) or message reprocessing (>=2.1.0).

New features

• New optional package Confluent.Kafka.OAuthBearer.Aws provides AWS IAM-based
  OAUTHBEARER authentication via AWS STS GetWebIdentityToken. Activate by
  setting SaslOauthbearerMethod = SaslOauthbearerMethod.Oidc,
  SaslOauthbearerMetadataAuthenticationType.AwsIam, and supplying
  region and audience in SaslOauthbearerConfig. See the package's README
  for details.

Enhancements

• References librdkafka.redist 2.15.0. Refer to the librdkafka v2.15.0 release notes for more information.
• Added support for .NET 10 (LTS) and dropped support for .NET 6 (end of support since November 2024). The library now multi-targets net8.0 and net10.0 alongside netstandard2.0 and net462. Builds on the approach proposed in #​2545 by @​ffernandolima, adapted for the centralized Directory.Build.props structure on current master.
• Adds support for union-of-pools/ auto pool mapping for Schema Registry (#​2634)

Fixes

• Throw an InvalidOperationException when calling StoreOffset with an EOF consume result, to match Commit behavior (#​2621)
• Handle non-http errors during retries (#​2633)

2.14.2

Enhancements

• References librdkafka.redist 2.14.2. Refer to the librdkafka v2.14.2 release notes for more information.
• Add IHeader overload to Headers.Add() method (#​2604)

Fixes

• Handle anyOf/allOf in JSON transforms (#​2611)
• Allow encrypting enum for JObject in dotnet (#​2615)
• Fix 'occured' -> 'occurred' typo in ConsumeException XML doc comments (#​2609)

Commits viewable in compare view.

Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting @dependabot rebase.

---

Dependabot commands and options

You can trigger Dependabot actions by commenting on this PR:

• @dependabot rebase will rebase this PR
• @dependabot recreate will recreate this PR, overwriting any edits that have been made to it
• @dependabot show <dependency name> ignore conditions will show all of the ignore conditions of the specified dependency
• @dependabot ignore this major version will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this minor version will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this dependency will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself)