Contents

#!/usr/bin/env ruby
require_relative "../lib/kafkr.rb"

PORT = ENV["KAFKR_PORT"] || 4000

begin
  require "kafkr"
rescue LoadError => e
  puts "Failed to load Kafkr: #{e.message}"
  exit(1)
end

begin
  server = Kafkr::Log.new(PORT.to_i)
  puts "Kafkr Log version #{Kafkr::VERSION} started on port #{PORT}!"
  server.start
rescue => e
  puts "An error occurred: #{e.message}"
  exit(1)
rescue Interrupt
  puts "\nLog server shutting down gracefully..."
  server.stop if server.respond_to?(:stop)
  exit(0)
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
kafkr-0.18.0	exe/kafkr
kafkr-0.13.0	exe/kafkr
kafkr-0.11.0	exe/kafkr
kafkr-0.10.0	exe/kafkr
kafkr-0.9.1	exe/kafkr