/kafkaesque-wooga

A JRuby-based event stream processing framework for Kafka.

Primary LanguageRubyMIT LicenseMIT

Kafkaesque

A JRuby-based event stream processing framework for Kafka.

Example

Kafkaesque::Consumer.new(
  :handler => MyHandler,
  :event => MyEvent,
  :number_of_workers => 5,
  :kafka => {
    :host => '192.168.0.1',
    :topics => %w[foo bar]
  }
).start

Contributing to Kafkaesque

  • fork the project
  • start a feature branch
  • make sure to add tests
  • please try not to mess with the Rakefile, version, or history

Copyright

Copyright (c) 2011, 2012 Wooga GmbH, Berlin