gems waterdrop 2.10.10
v2.10.10

2 hours ago
  • [Feature] Add the partition_count_cache_ttl_ms setting to configure the process-wide karafka-rdkafka partition count cache TTL (default nil leaves it untouched).
  • [Change] Require karafka-rdkafka >= 0.32.0.
  • [Change] Use the producer id (ProducerNotTransactionalError, EarlyTransactionExitNotAllowedError) or the event id (StatisticsNotEnabledError) as the error message instead of a sentence.
  • [Maintenance] Document the errors raised by ensure_active! and ensure_connection_pool_gem!, and fix the MessageInvalidError namespace in validate_message! YARD.
  • [Maintenance] Document that max_wait_timeout is omitted, not set to nil, to use the producer default in Producer#with and Variant#initialize YARD.
  • [Fix] Send a message buffered through a variant with that variant's topic_config at flush, and a message buffered through the producer with the default one, whichever producer or variant flushes the buffer.
  • [Fix] Raise VariantInvalidError instead of NoMethodError when Producer#with gets a topic_config that is not a hash (e.g. nil).
  • [Fix] Make Clients::Buffered and Clients::Dummy safe to produce to from many threads, so on JRuby no buffered message is lost and no offset is assigned twice.

Don't miss a new waterdrop release

NewReleases is sending notifications on new releases.