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