Modern and performant Kafka client library for Ruby based on librdkafka
rd_kafka_offset_store with rd_kafka_offsets_store (mensfeld)topic_name as topic in the delivery report (mensfeld)label producer handler and report reference for improved traceability (mensfeld)create_result on producer handle (mensfeld)-1 instead of nil in case partition_count failure (mensfeld).#rd_kafka_poll (mensfeld)uint8_t does not exist on Apple Silicon (mensfeld)RD_KAFKA_RESOURCE_BROKER constant reference (mensfeld)PARTITIONS_COUNT_TTL (mensfeld)matching_acl_pattern_type to matching_acl_resource_pattern_type to align the whole API (mensfeld)Admin#metadata (mensfeld)Admin#create_partitions (mensfeld)Admin#delete_group utility (piotaixr)#assignment_lost? on a consumer to check for involuntary assignment revocation (mensfeld)#lag and #query_watermark_offsets default timeouts from 100ms to 1000ms. This will compensate for network glitches and remote clusters operations (mensfeld)SecureRandom.uuid instead of random for test consumer groups (mensfeld)raise_response_error flag to the Rdkafka::AbstractHandle.statistics_callback as nil to reset predefined settings configured by a different gem (mensfeld)#purge to remove any outstanding requests from the producer (mensfeld)librdkafka to 2.2.0 (mensfeld)250 ms to 2000 ms default to allow for remote cluster operations via rdkafka-ruby (mensfeld)#name for producers and consumers (mensfeld)#poll on native kafka creation to handle oauthbearer cb (mensfeld)#flush does not handle the timeouts errors by making it return true if all flushed or false if failed. We do not raise an exception here to keep it backwards compatible (mensfeld)