Fixes
- Fixed a deadlock situation that was occurring during disposal of
Producer
instances after using async variants of theProduceAsync
method (#92). - Fixed a null check related bug in
Consumer.MemberId
(#222).
Enhancements
- References librdkafka.redist v0.11.0 which includes support for the new Kafka message format (MsgVersion 2) which makes this client transparently compatible use with the EOS (Exactly-Once-Semantics) supporting Java client released with Apache Kafka v0.11.0. For more information refer to the librdkafka v0.11.0 release notes.
- Any exceptions thrown whilst deserializing consumed messages are now caught and more conveniently exposed via
OnConsumeError
events (#175). - Additional bootstrap servers can now be added after construction of a
Producer
orConsumer
using the newAddBrokers
method (#209). - A strong name version of the library is now build which is available on nuget.org as Confluent.Kafka.StrongName (#168).
- Obsoleted overloads of various methods on
Producer
andConsumer
that can block indefinitely and can't be cancelled, enforcing use of variants with a timeout (#184).
This release includes external PRs from @zikifer, @andreycha and @treziac - thanks for your help! Also thanks to @chiru1205 for extensive testing under high load scenarios and @treziac once more for his valuable code reviews.