Class: QuakeLogParser::KafkaTopicConsumer

Inherits:
Karafka::BaseConsumer
  • Object
show all
Defined in:
lib/quake-log-parser/kafka_topic_consumer.rb

Instance Method Summary collapse

Instance Method Details

#consume ⇒ Object 



5
6
7
8
9
10
 
# File 'lib/quake-log-parser/kafka_topic_consumer.rb', line 5

def consume
  ::Karafka.logger.info "[QuakeLogParser::KafkaTopicConsumer] Consuming #{messages.size} messages from TOPIC #{topic.name}"
  kafka_topic_reader = ::QuakeLogParser::KafkaTopicReader.new(messages)
  kafka_topic_reader.read
  ::Karafka.logger.info "[QuakeLogParser::KafkaTopicConsumer] Results: #{kafka_topic_reader.results}"
end