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 collapse

VERSION =
"3.2.3"

Class Method Summary collapse

Class Method Details

.loggerObject



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

def logger
  @logger ||= Logger.new
end