lib/rdkafka/config.rb in rdkafka-0.12.0.beta.1 vs lib/rdkafka/config.rb in rdkafka-0.12.0.beta.2

@@ -177,10 +177,10 @@
       # Create Kafka config
       config = native_config(opaque)
       # Set callback to receive delivery reports on config
       Rdkafka::Bindings.rd_kafka_conf_set_dr_msg_cb(config, Rdkafka::Callbacks::DeliveryCallbackFunction)
       # Return producer with Kafka client
-      Rdkafka::Producer.new(Rdkafka::Producer::Client.new(native_kafka(config, :rd_kafka_producer))).tap do |producer|
+      Rdkafka::Producer.new(Rdkafka::Producer::Client.new(native_kafka(config, :rd_kafka_producer)), self[:partitioner]).tap do |producer|
         opaque.producer = producer
       end
     end
 
     # Create an admin instance with this configuration.