Exception: Fluent::Rdkafka2Output::EnqueueRate::LimitExceeded

Inherits:

StandardError

• Object
• StandardError
• Fluent::Rdkafka2Output::EnqueueRate::LimitExceeded

Defined in:

lib/fluent/plugin/out_rdkafka2.rb

Instance Attribute Summary

• #next_retry_clock ⇒ Object readonly

  Returns the value of attribute next_retry_clock.

Instance Method Summary

• #initialize(next_retry_clock) ⇒ LimitExceeded constructor

  A new instance of LimitExceeded.

Constructor Details

#initialize(next_retry_clock) ⇒ LimitExceeded

Returns a new instance of LimitExceeded.

# File 'lib/fluent/plugin/out_rdkafka2.rb', line 144

def initialize(next_retry_clock)
  @next_retry_clock = next_retry_clock
end

Instance Attribute Details

#next_retry_clock ⇒ Object (readonly)

Returns the value of attribute next_retry_clock.

# File 'lib/fluent/plugin/out_rdkafka2.rb', line 143

def next_retry_clock
  @next_retry_clock
end