out_rdkafka.rb in fluent-plugin-kafka-0.10.0

- old
+ new

@@ -62,11 +62,11 @@
   config_param :compression_codec, :string, :default => nil,
                :desc => <<-DESC
 The codec the producer uses to compress messages.
 Supported codecs: (gzip|snappy)
 DESC
-
+  config_param :max_send_limit_bytes, :size, :default => nil
   config_param :rdkafka_buffering_max_ms, :integer, :default => nil
   config_param :rdkafka_buffering_max_messages, :integer, :default => nil
   config_param :rdkafka_message_max_bytes, :integer, :default => nil
   config_param :rdkafka_message_max_num, :integer, :default => nil
   config_param :rdkafka_delivery_handle_poll_timeout, :integer, :default => 30
@@ -282,10 +282,10 @@
     loop do
       begin
         handler = producer.produce(topic: topic, payload: record_buf, key: message_key, partition: partition)
         return handler
       rescue Exception => e
-        if e.code == :queue_full
+        if e.respond_to?(:code) && e.code == :queue_full
           if attempt <= @max_enqueue_retries
             log.warn "Failed to enqueue message; attempting retry #{attempt} of #{@max_enqueue_retries} after #{@enqueue_retry_backoff}s"
             sleep @enqueue_retry_backoff
             attempt += 1
           else