Method: Rdkafka::Consumer#unsubscribe

Defined in:
lib/rdkafka/consumer.rb

#unsubscribe ⇒ nil

Unsubscribe from all subscribed topics.

Returns:

  • (nil)

Raises:

[View source] [View on GitHub]

88
89
90
91
92
93
94
95
96
97
 
# File 'lib/rdkafka/consumer.rb', line 88

def unsubscribe
  closed_consumer_check(__method__)

  response = @native_kafka.with_inner do |inner|
    Rdkafka::Bindings.rd_kafka_unsubscribe(inner)
  end
  if response != 0
    raise Rdkafka::RdkafkaError.new(response)
  end
end