module Kafka::Retryable

Current Kafka::Retryable version

Constants

VERSION

Public Class Methods

config() click to toggle source

return config object

# File lib/kafka/retryable.rb, line 5
def config
  Config.config
end
enabled?() click to toggle source
# File lib/kafka/retryable.rb, line 14
def enabled?
 config.failure_handling.enabled
end
setup(&block) click to toggle source

Provides a block to override default config

# File lib/kafka/retryable.rb, line 10
def setup(&block)
  Config.setup(&block)
end