0.8.3

• #53 Fixes major off-by one issue with offsets in Kafka manual committer
• Automatically stops the publisher actor after it fails - allows simpler manual restarting
• Other minor fixes

0.8.2

This is a bugfix release, addressing #41 and #43

0.8.1

• Add cancel() API to the PublisherWithCommitSink to allow elegant closing of all underlying resources
• Properly replace log4j with slf4j

0.8.0

Details: https://softwaremill.com/whats-new-in-reactive-kafka/

0.7.2

• Critical fix for the Java API

0.7.1

Adds Java API

0.7.0

• Introduces new API for creating producers / consumers
  • allows passing custom dispatcher name
  • allows defining custom RequestStrategy
  • allows passing kafka-specific properties
• Fixes #21 by supporting akka-based error handling (more in README)

0.6.0

• Fixed error handling (#10)
• Some minor improvements and additional tests

0.5.0

• Updated dependencies (Akka, reactive-streams)
• Fixed a bug causing high CPU load and rendering actors non-cancellable
• Removed some redundant checks (now performed by underlying Akka code)

0.4.0

• Support for Encoders/Decoders of different message types.
  This is a breaking change that enforces update of client code to explicitly decalare a proper Decoder/Encoder instead of using raw Strings. In case you want to keep String-based messages, use a new StringEncoder() or new StringDecoder(). Thanks @javierarrieta for this contrbution! (#7)
• Fixed the consumer behavior when new messages appear in stream.
  When connected to a Kafka queue, the flow was consuming all the present elements but after that, new elements were not polled correctly. This fix assures that an ActorPublisher keeps polling Kafka for new elements if there is demand.