Rafka Versions Save

This is a maintenance release with no changes.

This is a release refactoring the internal data structures of Rafka as detailed in Rafka Rethinking design doc.

Changed

• [BREAKING] Drop support for multiple Consumers per Client. From now on, only a single Consumer can be associated with a Client instance

• [INTERNAL] The ConsumerManager module as well as the respective functionality for managing Consumers has been completely dropped from the source. Now, the handling of Consumers is split between the Server and the respective Client instances.

Added

• Add support for the MONITOR command [#80]

Changed

• [BREAKING] Drop support for librdkafka 0.11.4 and before. librdkafka 0.11.5 or later is now required [#76]

• The consumer will now strip "unset" offsets (aka those of OffsetInvalid type) from the logging output [#79]

This is a maintenance release adding support for librdkafka 0.11.6 and beyond.

Fixed

• With librdkafka 0.11.6 and 1.0.0, consumers could block indefinitely in BLPOP, resulting in rafka being unable to shutdown [#77]

Added

• "Unsupported command" errors now contain the actual command that was attempted by the client [fa45217]

Changed

• If there are no messages to be consumed, BLPOP returns a "null array" instead of a "null string", adhering to the Redis protocol. This is an internal change that shouldn't affect clients [adf3650]

• Connection write/flush errors are not logged anymore [686af22]

This is a maintenance release.

Added

• The server now logs errors during writing or flushing a response to the client [71aacf5]

Changed

• Incoming message size limit is bumped from 64kB to 32MB [75fa7ef]

Fixed

• Properly return all parse errors to clients [db39b5f]

Added

• Support for listing topics [#66]
• Flag for displaying the rafka version (--version/-v) [c650dd0]

Changed

• Shutdown process is more robust with less downtime for producers [#68]

This is a backwards incompatible release.

Fixed

• Ignore non-critical "Poll GroupCoordinator" errors [#69]

Changed

• [BREAKING] --kafka/-k flag is renamed to --config/-c [9be4ea8]

Fixed

• Consumers failed to start if librdkafka configuration provided from clients contained numeric values [118c36a]