Update the requires for the sample scripts.

ext/hermann/hermann_lib.c

@@ -101,6 +101,18 @@ static void msg_delivered(rd_kafka_t *rk,
 	if (error_code) {
 		fprintf(stderr, "%% Message delivery failed: %s\n",
 			rd_kafka_err2str(error_code));
+		/* todo: should raise an error? */
+	} else {
+	    // Yield the data to the Producer's block
+        if (rb_block_given_p()) {
+            VALUE value = rb_str_new((char *)payload, len);
+            rb_yield(value);
+        }
+        else {
+            if (DEBUG) {
+                fprintf(stderr, "No block given\n"); // todo: should this be an error?
+            }
+        }
 	}
 }
 

scripts/consume_msgs_loop_localhost.rb

@@ -1,4 +1,6 @@
-require 'hermann'
+require 'rubygems'
+require 'lib/hermann'
+require 'lib/hermann/consumer'
 
 c = Hermann::Consumer.new( "lms_messages", "localhost:9092", 0 )
 t1 = 0

scripts/produce_1M_msgs_localhost.rb

@@ -1,4 +1,7 @@
-require 'hermann'
+require 'rubygems'
+require 'lib/hermann'
+require 'lib/hermann/consumer'
+
 p = Hermann::Producer.new("lms_messages", "localhost:9092")
 arr = (0..1000000).to_a.map { |x| "message_#{x}"}
 t1 = Time.now

scripts/produce_msgs_1min_localhost.rb

@@ -1,7 +1,8 @@
 # Produce messages for a given amount of time
 
 require 'rubygems'
-require 'hermann'
+require 'lib/hermann'
+require 'lib/hermann/consumer'
 
 stopTime = Time.now + 60 # One minute from now
 p = Hermann::Producer.new("lms_messages")