Ruby Kafka Versions Save

A Ruby client library for Apache Kafka

v0.5.0.beta4

6 years ago

v0.5.0.beta5

6 years ago

v0.5.0.beta6

6 years ago

v0.5.1.beta1

6 years ago

v0.5.1.beta2

6 years ago

v0.4.3

6 years ago
  • Restart the async producer thread automatically after errors.
  • Include the offset lag in batch consumer metrics (Statsd).
  • Make the default max_wait_time more sane.
  • Fix issue with cached default offset lookups (#431).
  • Upgrade to Datadog client version 3.

v0.5.0

6 years ago
  • Drops support for Kafka 0.9 in favor of Kafka 0.10 (#381)!
  • Handle cases where there are no partitions to fetch from by sleeping a bit (#439).
  • Handle problems with the broker cache (#440).
  • Shut down more quickly (#438).

v0.5.1

6 years ago

Requires Kafka 0.10.1+ due to usage of a few new APIs.

  • Fix bug when using compression (#458).
  • Update the v3 of the Fetch API, allowing a per-request max_bytes setting (#468).
  • Make #deliver_message more resilient using retries and backoff.
  • Add support for SASL SCRAM authentication (#465).
  • Refactor and simplify SASL code.
  • Fix issue when a consumer resets a partition to its default offset.
  • Allow specifying a create time for messages (#481).