Minor fixes

https://www.nuget.org/packages/Confluent.Kafka.Dataflow/2.0.1

Transaction/EoS Support

Transactions and EoS are now supported using TargetBuilder<T>. Also includes linked message targets for committing offsets, messages on consume/delivery handlers, and more. See README for usage examples.

https://www.nuget.org/packages/Confluent.Kafka.Dataflow/2.0.0

Stable API

See README for usage notes. Transactions/EOS not supported yet, but will be in a future version.
https://www.nuget.org/packages/Confluent.Kafka.Dataflow/1.0.0

Heartbeat reassignment fix

• Fix faulting on reassignment with pending consuming
• Better fault propagation

Consumer heartbeat + refactoring

Extend source completion

* Wait until safe to dispose consumer

Delivered offsets

Support representing a producer as a source for delivered (produced/committed) offsets.

v0.1.1

Fix offsets not being committed bug

Working prototype

v0.1.0

Batch produce blocks