lib/rdkafka/config.rb in rdkafka-0.17.0 vs lib/rdkafka/config.rb in rdkafka-0.18.0

@@ -144,9 +144,11 @@
     #
     # @param config_hash [Hash{String,Symbol => String}] The config options for rdkafka
     #
     # @return [Config]
     def initialize(config_hash = {})
+      Callbacks.ensure_ffi_running
+
       @config_hash = DEFAULT_CONFIG.merge(config_hash)
       @consumer_rebalance_listener = nil
       @consumer_poll_set = true
     end