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|