module CC::Kafka
Constants
- ConfigurationError
- VERSION
Attributes
logger[W]
offset_model[W]
ssl_ca_file[RW]
ssl_pem_file[RW]
statsd[W]
Public Class Methods
logger()
click to toggle source
# File lib/cc/kafka.rb, line 22 def logger @logger ||= Logger.new(STDOUT) end
offset_model()
click to toggle source
# File lib/cc/kafka.rb, line 26 def offset_model if @offset_model.nil? raise ConfigurationError, "Kafka.offset_model not set" end @offset_model end
statsd()
click to toggle source
# File lib/cc/kafka.rb, line 34 def statsd @statsd ||= DummyStatsd.new end