• [Enhancement] Provide ability to label message dispatches for increased observability.
• [Enhancement] Provide ability to commit offset during the transaction with a consumer provided.
• [Change] Change transactional message purged error type from message.error to librdkafka.dispatch_error to align with the non-transactional error type.
• [Change] Remove usage of concurrent ruby.