Class: Julewire::Karafka::Configuration

Inherits:

Object

• Object
• Julewire::Karafka::Configuration

Includes:

Core::Integration::Settings

Defined in:

lib/julewire/karafka/configuration.rb

Constant Summary

IMPORTANT_CONSUMER_EVENT_NAMES =

%w[
  app.initialized
  app.running
  app.quiet
  app.stopped
  consumer.consumed
  consumer.revoked
  consumer.shutdown
  dead_letter_queue.dispatched
  filtering.throttled
  rebalance.partitions_assigned
  rebalance.partitions_revoked
  swarm.node.after_fork
  worker.completed
  error.occurred
].freeze

IMPORTANT_PRODUCER_EVENT_NAMES =

%w[
  producer.connected
  producer.closed
  message.produced_async
  message.produced_sync
  message.acknowledged
  messages.produced_async
  messages.produced_sync
  transaction.committed
  transaction.aborted
  buffer.flushed_async
  buffer.flushed_sync
  error.occurred
].freeze