Class: ApplicationConsumer

Inherits:

Rimless::Consumer::Base

• Object
• Karafka::BaseConsumer
• Rimless::Consumer::Base
• ApplicationConsumer

Defined in:

lib/rimless/tasks/templates/application_consumer.rb

Overview

The overall shared base consumer for Apache Kafka messages. Just write your own specific consumer and inherit this one to share logic.

Direct Known Subclasses

CustomConsumer

Instance Attribute Summary

Attributes inherited from Rimless::Consumer::Base

#message

Method Summary

Methods inherited from Rimless::Consumer::Base

#arguments, build_for_job, #consume, #event, job_deserializers