Franz 3.0.0
dotnet add package Franz --version 3.0.0
NuGet\Install-Package Franz -Version 3.0.0
<PackageReference Include="Franz" Version="3.0.0" />
paket add Franz --version 3.0.0
#r "nuget: Franz, 3.0.0"
// Install Franz as a Cake Addin #addin nuget:?package=Franz&version=3.0.0 // Install Franz as a Cake Tool #tool nuget:?package=Franz&version=3.0.0
Kafka client for .NET written in F#
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET Framework | net45 is compatible. net451 was computed. net452 was computed. net46 was computed. net461 was computed. net462 was computed. net463 was computed. net47 was computed. net471 was computed. net472 was computed. net48 was computed. net481 was computed. |
-
- FSharp.Core (>= 4.0.0.1)
- Snappy.NET
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
A lot of bugfixes and new features have been included in this release.
Fixed a bug which would throw an exception when a consumer failed while communicating with a broker. Instead of throwing an exception, we now try to reconnect, and only if this fails throw an exception. The retry interval is defined in the consumer options as ConnectionRetryInterval.
Support for specifying which partitions to send messages to. This is done by specifying a key along with the messages, and providing a function used to select the partition based on the key. To use round-robin as previously, you should use the new RoundRobinProducer.
Consumed messages now also contains the offset and partition for which the message were consumed.
Fixed a bug which would allow you set an offset for a partition, not in the partition whitelist.
New consumer, ChunkedConsumer, which consume messages in chunks, and won't use as much memory.
Support for version 2 of the OffsetCommit protocol.
Fixed bug where OffsetManager for version 1 of the OffsetCommit protocol did not use the default timestamp value. This resulted in not using the expected offset retention time.
Increment correlation id on each request.
Rename Set/GetOffsets methods on the consumer to Set/GetPosition, to clearly indicate these methods has nothing with the offsets handled by the OffsetManager to do.
Support user-defined logging by implementing the ILogger interface and set the logger through LogConfiguration.
Move partition whitelist into ConsumerOptions.
Fix bug in producer where an unavailable broker would result in not refreshing the metadata.
Fix bug where consuming data from a broker going down would result in a infinite loop.
Experimental support for reading the state and connection to a Kafka cluster through the Zookeeper cluster.
FSharp.Core is no longer pinned to a specific version