lib/karafka/base_consumer.rb from karafka/karafka

lib/karafka/base_consumer.rb

2 hrs

  class BaseConsumer
    # Allow for consumer instance tagging for instrumentation
    include ::Karafka::Core::Taggable

    extend Forwardable

Found in lib/karafka/base_consumer.rb - About 2 hrs to fix

karafka/karafka