You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This commit was created on GitHub.com and signed with GitHub’s verified signature.
[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.