- [Feature] Add the
partition_count_cache_ttl_mssetting to configure the process-wide karafka-rdkafka partition count cache TTL (defaultnilleaves 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!andensure_connection_pool_gem!, and fix theMessageInvalidErrornamespace invalidate_message!YARD. - [Maintenance] Document that
max_wait_timeoutis omitted, not set tonil, to use the producer default inProducer#withandVariant#initializeYARD. - [Fix] Send a message buffered through a variant with that variant's
topic_configat flush, and a message buffered through the producer with the default one, whichever producer or variant flushes the buffer. - [Fix] Raise
VariantInvalidErrorinstead ofNoMethodErrorwhenProducer#withgets atopic_configthat is not a hash (e.g.nil). - [Fix] Make
Clients::BufferedandClients::Dummysafe to produce to from many threads, so on JRuby no buffered message is lost and no offset is assigned twice.