v1.4.0
版本发布时间: 2020-04-03 23:19:39
confluentinc/confluent-kafka-dotnet最新发布版本:v2.5.2(2024-08-07 15:21:59)
Enhancements
- References librdkafka v1.4.0. Refer to the release notes for more information. Headline features:
- KIP-98: Producer support for transactions (@edenhill). This is the final piece in the puzzle required to enable exactly once stream processing (EOS) in .NET.
- KIP-345: Static consumer group membership (@rnpridgeon).
- KIP-511: Client name and version are now provided to brokers.
- Added Protobuf and JSON serdes including integration with Schema Registry.
- Switched to the official Apache Avro nuget package, which includes support for logical types, and all fixes from the Confluent fork, which has now been discontinued.
- Message headers are now exposed to serdes via
SerializationContext
(@pascalconfluent). - Added a
CancellationToken
parameter to theProduceAsync
methods. - Uncaught exceptions thrown in handler methods are now propagated to the initiating function, or in the case of error or log events, ignored. Previously, they would cause the application to terminate.
- Added a WordCount example demonstrating a streaming map-reduce application with exactly-once processing.
Changes
- Some internal improvements to the
Consmer
(thanks to @andypook). - BREAKING CHANGE:
net452
is no longer a target framework ofConfluent.SchemaRegistry
orConfluent.SchemaRegistry.Serdes
due to the switch to the official Apache Avro package which only targetsnetstandard2.0
. - Marked properties on
ConsumeResult
that simply delegate to the corresponding properties onConsumeResult.Message
as obsolete.
Fixes
- Fixed an
ArgumentNullException
regression inListGroups
(thanks to @andypook).