Module: CC::Kafka

Defined in:
lib/cc/kafka.rb,
lib/cc/kafka/version.rb,
lib/cc/kafka/consumer.rb,
lib/cc/kafka/producer.rb,
lib/cc/kafka/producer/http.rb,
lib/cc/kafka/producer/poseidon.rb,
lib/cc/kafka/offset_storage/memory.rb,
lib/cc/kafka/offset_storage/minidoc.rb

Defined Under Namespace

Modules: OffsetStorage Classes: Consumer, DummyStatsd, Producer

Constant Summary collapse

ConfigurationError = 
Class.new(StandardError)
VERSION = 
"0.11.0"

Class Attribute Summary collapse

Class Attribute Details

.logger ⇒ Object 



22
23
24
 
# File 'lib/cc/kafka.rb', line 22

def logger
  @logger ||= Logger.new(STDOUT)
end

.offset_model ⇒ Object 



26
27
28
29
30
31
32
 
# 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

.ssl_ca_file ⇒ Object

Returns the value of attribute ssl_ca_file.



18
19
20
 
# File 'lib/cc/kafka.rb', line 18

def ssl_ca_file
  @ssl_ca_file
end

.ssl_pem_file ⇒ Object

Returns the value of attribute ssl_pem_file.



18
19
20
 
# File 'lib/cc/kafka.rb', line 18

def ssl_pem_file
  @ssl_pem_file
end

.statsd ⇒ Object 



34
35
36
 
# File 'lib/cc/kafka.rb', line 34

def statsd
  @statsd ||= DummyStatsd.new
end