Commit Graph

15 Commits

Author SHA1 Message Date
Ben Osheroff c2540a8410 update api to have #topic(topic) as well as #topics
also add Partition#consumer to instantiate a coonsumer object on the
particular partition
2015-06-11 15:29:02 -07:00
Ben Osheroff 326b428b34 slap a friendlier face on the returned metadata interface 2015-05-19 13:34:39 -07:00
Ben Osheroff 5942e1810b fix bug, constantize TIMEOUT_MS, add README.md info 2015-05-19 11:33:13 -07:00
Ben Osheroff e38b626b71 Add metadata API to Hermann::Discovery module 2015-05-19 11:13:27 -07:00
Ben Osheroff 8b7a31a232 add mri script 2015-04-28 10:09:02 -07:00
Ben Osheroff 3792ee206b unify jruby/mri Consumer#initialize
While we do require different options between jruby & mri, there is a
common "topic" option.  The rest we pass in the options hash.
2015-04-27 09:32:16 -07:00
R. Tyler Croy 5de9612882 Bundle a known good version of librdkafka (0.8.4) with Hermann
This reduces the need for the librdkafka system dependency and results in
statically linking librdkafka.a against the C extension.

There's a few hacks in extconf.rb specifically to deal with librdkafka's build
system, as well as apply checksumming to the downloaded file

Fixes #8
2014-09-12 16:13:19 -07:00
R. Tyler Croy a0697f5b66 Refactor out the necessity for Hermann::Timeout and just rely in a Ruby-based busyloop 2014-09-09 16:45:17 -07:00
R. Tyler Croy 9014551d10 Make use of Hermann::Timeout when ticking the Producers reactor to safely block for a value
This adds a requirement for 1.8.7 clients to install the SystemTimer gem for
timing out on Hermann::Result#value(timeout) to block and timeout correctly

Fixes #25
2014-09-09 14:40:10 -07:00
R. Tyler Croy ed36300265 Pass a pointer to a Hermann::Result into the message delivery callback
Provided that /something/ is ticking the librdkafka reactor underneath, the
Hermann::Result will be updated with the message delivery status when that's
completed.

What's still missing is producer level error calbacks

Fixes #11
Fixes #15
Fixes #17
2014-09-04 14:31:29 -07:00
R. Tyler Croy dc9a057eaa Add a simple script to validate big message behavior
References #21
2014-09-04 14:29:29 -07:00
Stan Campbell e71ab6cd14 Update the requires for the sample scripts. 2014-09-04 10:52:27 -07:00
Stan Campbell 8aff9226b7 Add example scripts testing producer and consumer functionality. 2014-09-04 10:27:47 -07:00
Stan Campbell ba99648e0d Enable the 'x' perm on the scripts.
JIRA: REL-1051
2014-07-30 22:00:09 -07:00
Stan Campbell e7754c7e66 Add CI scripts for artifactory.
JIRA: REL-1051
2014-07-30 21:58:04 -07:00