Module: KafkaRest

Defined in:
lib/kafka_rest.rb,
lib/kafka_rest/topic.rb,
lib/kafka_rest/broker.rb,
lib/kafka_rest/client.rb,
lib/kafka_rest/schema.rb,
lib/kafka_rest/logging.rb,
lib/kafka_rest/version.rb,
lib/kafka_rest/consumer.rb,
lib/kafka_rest/partition.rb,
lib/kafka_rest/producable.rb,
lib/kafka_rest/event_emitter.rb,
lib/kafka_rest/schema_parser.rb,
lib/kafka_rest/consumer_stream.rb,
lib/kafka_rest/consumer_instance.rb

Defined Under Namespace

Modules: EventEmitter, Logging, Producable, SchemaParser Classes: Broker, Client, Consumer, ConsumerInstance, ConsumerStream, Partition, Schema, Topic

Constant Summary collapse

EMPTY_STRING = 
''.freeze
TWO_OCTET_JSON = 
'{}'.freeze
RIGHT_BRACE = 
'}'.freeze
VERSION = 
'0.1.1'.freeze

Class Method Summary collapse

Class Method Details

.logger ⇒ Object 



25
26
27
 
# File 'lib/kafka_rest.rb', line 25

def logger
  KafkaRest::Logging.logger
end