Method: Rdkafka::Producer::Client#close

Defined in:
lib/rdkafka/producer/client.rb

#close(object_id = nil) ⇒ Object 



33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/rdkafka/producer/client.rb', line 33

def close(object_id=nil)
  return unless @native

  # Indicate to polling thread that we're closing
  @polling_thread[:closing] = true
  # Wait for the polling thread to finish up
  @polling_thread.join

  Rdkafka::Bindings.rd_kafka_destroy(@native)

  @native = nil
end