lib/rdkafka/config.rb in rdkafka-0.6.0 vs lib/rdkafka/config.rb in rdkafka-0.7.0

- old
+ new

@@ -65,11 +65,11 @@ :"log.queue" => true }.freeze # Returns a new config with the provided options which are merged with {DEFAULT_CONFIG}. # - # @param config_hash [Hash<String,Symbol => String>] The config options for rdkafka + # @param config_hash [Hash{String,Symbol => String}] The config options for rdkafka # # @return [Config] def initialize(config_hash = {}) @config_hash = DEFAULT_CONFIG.merge(config_hash) @consumer_rebalance_listener = nil @@ -153,10 +153,10 @@ # Error that is raised when trying to set a nil logger class NoLoggerError < RuntimeError; end private - # This method is only intented to be used to create a client, + # This method is only intended to be used to create a client, # using it in another way will leak memory. def native_config(opaque=nil) Rdkafka::Bindings.rd_kafka_conf_new.tap do |config| # Create config @config_hash.merge(REQUIRED_CONFIG).each do |key, value|