Module: EventMachine::Kafka

Defined in:

lib/em-kafka.rb,
lib/em-kafka/client.rb,
lib/em-kafka/parser.rb,
lib/em-kafka/message.rb,
lib/em-kafka/version.rb,
lib/em-kafka/consumer.rb,
lib/em-kafka/producer.rb,
lib/em-kafka/connection.rb,
lib/em-kafka/event_emitter.rb,
lib/em-kafka/consumer_request.rb,
lib/em-kafka/producer_request.rb

Defined Under Namespace

Modules: EventEmitter Classes: Client, Connection, Consumer, ConsumerRequest, Message, Parser, Producer, ProducerRequest

Constant Summary

MESSAGE_MAX_SIZE =

1 MB

1048576

CONSUMER_POLLING_INTERVAL =

2 seconds

2

REQUEST_PRODUCE =

0

REQUEST_FETCH =

1

REQUEST_MULTIFETCH =

2

REQUEST_MULTIPRODUCE =

3

REQUEST_OFFSETS =

4

ERROR_NO_ERROR =

0

ERROR_OFFSET_OUT_OF_RANGE =

1

ERROR_INVALID_MESSAGE_CODE =

2

ERROR_WRONG_PARTITION_CODE =

3

ERROR_INVALID_RETCH_SIZE_CODE =

4

ERROR_DESCRIPTIONS =

{
  ERROR_NO_ERROR                => 'No error',
  ERROR_INVALID_MESSAGE_CODE    => 'Offset out of range',
  ERROR_INVALID_MESSAGE_CODE    => 'Invalid message code',
  ERROR_WRONG_PARTITION_CODE    => 'Wrong partition code',
  ERROR_INVALID_RETCH_SIZE_CODE => 'Invalid retch size code'
}

VERSION =

"0.0.2"

Class Method Summary

• .logger ⇒ Object
• .logger=(new_logger) ⇒ Object

Class Method Details

.logger ⇒ Object

# File 'lib/em-kafka.rb', line 39

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

.logger=(new_logger) ⇒ Object

# File 'lib/em-kafka.rb', line 43

def logger=(new_logger)
  @logger = new_logger
end