Module: Sbmt::KafkaProducer

Defined in:

lib/sbmt/kafka_producer.rb,
lib/sbmt/kafka_producer/types.rb,
lib/sbmt/kafka_producer/logger.rb,
lib/sbmt/kafka_producer/railtie.rb,
lib/sbmt/kafka_producer/version.rb,
lib/sbmt/kafka_producer/config/auth.rb,
lib/sbmt/kafka_producer/config/kafka.rb,
lib/sbmt/kafka_producer/base_producer.rb,
lib/sbmt/kafka_producer/error_tracker.rb,
lib/sbmt/kafka_producer/config/producer.rb,
lib/sbmt/kafka_producer/outbox_producer.rb,
lib/sbmt/kafka_producer/yabeda_configurer.rb,
lib/sbmt/kafka_producer/kafka_client_factory.rb,
lib/sbmt/kafka_producer/outbox_transport_factory.rb,
lib/sbmt/kafka_producer/instrumentation/tracing_middleware.rb,
lib/sbmt/kafka_producer/instrumentation/open_telemetry_loader.rb,
lib/sbmt/kafka_producer/instrumentation/open_telemetry_tracer.rb,
lib/sbmt/kafka_producer/instrumentation/yabeda_metrics_listener.rb

Defined Under Namespace

Modules: Config, Instrumentation, Types Classes: BaseProducer, Error, ErrorTracker, KafkaClientFactory, Logger, OutboxProducer, OutboxTransportFactory, Railtie, YabedaConfigurer

Constant Summary

VERSION =

"3.4.0"

Class Method Summary

• .logger ⇒ Object
• .middlewares ⇒ Object

Class Method Details

.logger ⇒ Object

# File 'lib/sbmt/kafka_producer.rb', line 18

def logger
  @logger ||= Logger.new
end

.middlewares ⇒ Object

# File 'lib/sbmt/kafka_producer.rb', line 22

def middlewares
  @middlewares ||= []
end