NuGet\Install-Package Franz -Version 3.0.0
dotnet add 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#
|.NET Framework||net45 net451 net452 net46 net461 net462 net463 net47 net471 net472 net48|
This package is not used by any NuGet packages.
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