Contents

# frozen_string_literal: true

require 'rimless'

# Setup the topic-consumer routing table and boot the consumer application
Rimless.consumer.topics(
  { app: :your_app, name: :your_topic } => CustomConsumer
).boot!

# Configure Karafka/ruby-kafka settings
# Rimless.consumer.configure do |config|
#   # See https://github.com/karafka/karafka/wiki/Configuration
#   # config.kafka.start_from_beginning = false
# end

# We want a less verbose logging on development
# Rimless.logger.level = Logger::INFO if Rails.env.development?

# Use a different Sidekiq queue for the consumer jobs
# Rimless.configuration.consumer_job_queue = :messages

Version data entries

24 entries across 24 versions & 1 rubygems

Version	Path
rimless-1.8.0	lib/rimless/tasks/templates/karafka.rb
rimless-1.7.7	lib/rimless/tasks/templates/karafka.rb
rimless-1.7.6	lib/rimless/tasks/templates/karafka.rb
rimless-1.7.5	lib/rimless/tasks/templates/karafka.rb
rimless-1.7.4	lib/rimless/tasks/templates/karafka.rb
rimless-1.7.3	lib/rimless/tasks/templates/karafka.rb
rimless-1.7.2	lib/rimless/tasks/templates/karafka.rb
rimless-1.7.1	lib/rimless/tasks/templates/karafka.rb
rimless-1.7.0	lib/rimless/tasks/templates/karafka.rb
rimless-1.6.0	lib/rimless/tasks/templates/karafka.rb
rimless-1.5.1	lib/rimless/tasks/templates/karafka.rb
rimless-1.5.0	lib/rimless/tasks/templates/karafka.rb
rimless-1.4.2	lib/rimless/tasks/templates/karafka.rb
rimless-1.4.1	lib/rimless/tasks/templates/karafka.rb
rimless-1.4.0	lib/rimless/tasks/templates/karafka.rb
rimless-1.3.0	lib/rimless/tasks/templates/karafka.rb
rimless-1.2.0	lib/rimless/tasks/templates/karafka.rb
rimless-1.1.1	lib/rimless/tasks/templates/karafka.rb
rimless-1.1.0	lib/rimless/tasks/templates/karafka.rb
rimless-1.0.4	lib/rimless/tasks/templates/karafka.rb