Breaking changes are prefixed with a "[BREAKING]" label.
- Do not log unknown events as producer errors. Introduce new stats key for keeping track of unknown producer events. These events do not include "Connection reset by peers" connection errors. [#90].
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.
-
[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.
- Add support for the MONITOR command [#80]
-
[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
OffsetInvalidtype) from the logging output [#79]
- With librdkafka 0.11.6 and 1.0.0, consumers could block indefinitely in BLPOP, resulting in rafka being unable to shutdown [#77]
- "Unsupported command" errors now contain the actual command that was attempted by the client [fa45217]
-
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]
- The server now logs errors during writing or flushing a response to the client [71aacf5]
- Incoming message size limit is bumped from 64kB to 32MB [75fa7ef]
- Properly return all parse errors to clients [db39b5f]
- Shutdown process is more robust with less downtime for producers [#68]
- Ignore non-critical "Poll GroupCoordinator" errors [#69]
- [BREAKING]
--kafka/-kflag is renamed to--config/-c[9be4ea8]
- Consumers failed to start if librdkafka configuration provided from clients contained numeric values [118c36a]
This is a maintenance release with no changes.
- Accept configuration from clients [#40]
- Consumer could hang indefinitely when closing [#59]
- Offset commit results are now visible in the logs [c73dae]
- Use librdkafka auto commit and offset store functionality
- Depend on librdkafka 0.11.4 and confluent-kafka-go 0.11.4