Class: Karafka::Pro::BaseConsumer

Inherits:
BaseConsumer show all
Defined in:
lib/karafka/pro/base_consumer.rb

Overview

Note:

In case of using lrj, manual pausing may not be the best idea as resume needs to happen after each batch is processed.

Karafka PRO consumer.

If you use PRO, all your consumers should inherit (indirectly) from it.

Direct Known Subclasses

ActiveJob::Consumer

Instance Attribute Summary

Attributes inherited from BaseConsumer

#client, #coordinator, #id, #messages, #producer, #topic

Method Summary

Methods inherited from BaseConsumer

#initialize, #on_after_consume, #on_before_consume, #on_before_enqueue, #on_consume, #on_revoked, #on_shutdown

Constructor Details

This class inherits a constructor from Karafka::BaseConsumer