Module: Sbmt::KafkaConsumer

Defined in:

lib/sbmt/kafka_consumer.rb,
lib/sbmt/kafka_consumer/cli.rb,
lib/sbmt/kafka_consumer/types.rb,
lib/sbmt/kafka_consumer/server.rb,
lib/sbmt/kafka_consumer/railtie.rb,
lib/sbmt/kafka_consumer/version.rb,
lib/sbmt/kafka_consumer/probes/host.rb,
lib/sbmt/kafka_consumer/probes/probe.rb,
lib/sbmt/kafka_consumer/base_consumer.rb,
lib/sbmt/kafka_consumer/inbox_consumer.rb,
lib/sbmt/kafka_consumer/app_initializer.rb,
lib/sbmt/kafka_consumer/routing/wildcards.rb,
lib/sbmt/kafka_consumer/yabeda_configurer.rb,
lib/sbmt/kafka_consumer/instrumentation/tracer.rb,
lib/sbmt/kafka_consumer/routing/wildcards/feature.rb,
lib/sbmt/kafka_consumer/routing/wildcards/contract.rb,
lib/sbmt/kafka_consumer/instrumentation/base_monitor.rb,
lib/sbmt/kafka_consumer/routing/consumer_mapper/base.rb,
lib/sbmt/kafka_consumer/routing/list_existing_topics.rb,
lib/sbmt/kafka_consumer/instrumentation/sentry_tracer.rb,
lib/sbmt/kafka_consumer/instrumentation/listener_helper.rb,
lib/sbmt/kafka_consumer/instrumentation/logger_listener.rb,
lib/sbmt/kafka_consumer/instrumentation/tracing_monitor.rb,
lib/sbmt/kafka_consumer/serialization/base_deserializer.rb,
lib/sbmt/kafka_consumer/serialization/json_deserializer.rb,
lib/sbmt/kafka_consumer/serialization/null_deserializer.rb,
lib/sbmt/kafka_consumer/instrumentation/chainable_monitor.rb,
lib/sbmt/kafka_consumer/instrumentation/liveness_listener.rb,
lib/sbmt/kafka_consumer/instrumentation/readiness_listener.rb,
lib/sbmt/kafka_consumer/routing/karafka_v1_consumer_mapper.rb,
lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb,
lib/sbmt/kafka_consumer/serialization/protobuf_deserializer.rb,
lib/sbmt/kafka_consumer/instrumentation/open_telemetry_loader.rb,
lib/sbmt/kafka_consumer/instrumentation/open_telemetry_tracer.rb,
lib/sbmt/kafka_consumer/instrumentation/yabeda_metrics_listener.rb

Defined Under Namespace

Modules: AppInitializer, Instrumentation, Probes, Routing, Serialization, Types Classes: BaseConsumer, CLI, ClientConfigurer, Config, Error, InboxConsumer, Railtie, Server, SimpleLoggingConsumer, SkipUndeserializableMessage, YabedaConfigurer

Constant Summary

VERSION =

"3.9.0"

Class Method Summary

• .logger ⇒ Object
• .process_batch_middlewares ⇒ Object
• .process_message_middlewares ⇒ Object

Class Method Details

.logger ⇒ Object

# File 'lib/sbmt/kafka_consumer.rb', line 26

def logger
  @logger ||= Rails.logger
end

.process_batch_middlewares ⇒ Object

# File 'lib/sbmt/kafka_consumer.rb', line 34

def process_batch_middlewares
  @process_batch_middlewares ||= []
end

.process_message_middlewares ⇒ Object

# File 'lib/sbmt/kafka_consumer.rb', line 30

def process_message_middlewares
  @process_message_middlewares ||= []
end