Contents

require "bundler/setup"
require "glass_octopus"

app = GlassOctopus.build do
  use GlassOctopus::Middleware::CommonLogger

  run Proc.new { |ctx|
    puts "Got message: #{ctx.message.key} => #{ctx.message.value}"
  }
end

def array_from_env(key, default:)
  return default unless ENV.key?(key)
  ENV.fetch(key).split(",").map(&:strip)
end

GlassOctopus.run(app) do |config|
  config.logger = Logger.new("glass_octopus.log")

  config.adapter :poseidon do |kafka_config|
    kafka_config.broker_list    = array_from_env("KAFKA_BROKER_LIST", default: %w[localhost:9092])
    kafka_config.zookeeper_list = array_from_env("ZOOKEEPER_LIST", default: %w[localhost:2181])
    kafka_config.topic          = ENV.fetch("KAFKA_TOPIC", "mytopic")
    kafka_config.group          = ENV.fetch("KAFKA_GROUP", "mygroup")
    kafka_config.logger         = config.logger
  end

  config.executor = Concurrent::ThreadPoolExecutor.new(
    max_threads: 25,
    min_threads: 7
  )

  config.shutdown_timeout = 30
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
glass_octopus-1.1.0	example/advanced.rb
glass_octopus-1.0.0	example/advanced.rb