Sha256: 276f30c7be6a5872814af0033dd6514b99a899260ba4f7770322e022b2ed7974
Contents?: true
Size: 1.56 KB
Versions: 14
Compression:
Stored size: 1.56 KB
Contents
# frozen_string_literal: true
# Non Ruby on Rails setup
ENV['RACK_ENV'] ||= 'development'
ENV['KARAFKA_ENV'] ||= ENV['RACK_ENV']
Bundler.require(:default, ENV['KARAFKA_ENV'])
Karafka::Loader.load(Karafka::App.root)
# Ruby on Rails setup
# Remove whole non-Rails setup that is above and uncomment the 4 lines below
# ENV['RAILS_ENV'] ||= 'development'
# ENV['KARAFKA_ENV'] = ENV['RAILS_ENV']
# require ::File.expand_path('../config/environment', __FILE__)
# Rails.application.eager_load!
class KarafkaApp < Karafka::App
setup do |config|
config.kafka.seed_brokers = %w[kafka://127.0.0.1:9092]
config.client_id = 'example_app'
config.backend = :inline
config.batch_fetching = true
# Uncomment this for Rails app integration
# config.logger = Rails.logger
end
after_init do |config|
# Put here all the things you want to do after the Karafka framework
# initialization
end
# Comment out this part if you are not using instrumentation and/or you are not
# interested in logging events for certain environments. Since instrumentation
# notifications add extra boilerplate, if you want to achieve max performance,
# listen to only what you really need for given environment.
Karafka.monitor.subscribe(Karafka::Instrumentation::Listener)
consumer_groups.draw do
# topic :example do
# consumer ExampleConsumer
# end
# consumer_group :bigger_group do
# topic :test do
# consumer TestConsumer
# end
#
# topic :test2 do
# consumer Test2Consumer
# end
# end
end
end
KarafkaApp.boot!
Version data entries
14 entries across 14 versions & 1 rubygems