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