- [Maintenance] Rename the positional topic name parameters of
Producer#partition_count,Clients::Buffered#messages_forand the Datadog metrics listener totopic_name. - [Maintenance] Rename the positional topic name parameter of
Clients::Dummy::Handle#initializetotopic_name. - [Maintenance] Declare
rakein theGemfile. It came only throughkarafka-rdkafka, which will stop depending on it for precompiled platform gems. - [Fix] Copy the buffer in
Producer#messages(and so thebuffer.flushed_async/buffer.flushed_syncpayloads) under a dedicated lock, so reading it while other threads buffer no longer raisesConcurrencyErroron JRuby. - [Fix] Re-buffer the undispatched rest of a
#flushbatch when a concurrent#closestops it, and expose the handles dispatched before the close asProducerClosedError#dispatched. - [Fix] Copy the buffer in
Producer#messages(and so thebuffer.flushed_async/buffer.flushed_syncpayloads) under a dedicated lock, so reading it while other threads buffer no longer raisesConcurrencyErroron JRuby.