Run integration specs on travis-ci

.travis.yml

@@ -1,4 +1,12 @@
 laguage: ruby
+
+before_install:
+  - spec/setup_kafka.sh
+
+env: KAFKA_PATH=./spec/kafka/
+
+script: ./script/cibuild
+
 rvm:
   - 1.9.3
   - 2.0.0
@@ -10,4 +18,5 @@ rvm:
 matrix:
   allow_failures:
     - rvm: ruby-head
+    - rvm: jruby-head
     - rvm: rbx-19mode

lib/poseidon/partition_consumer.rb

@@ -96,7 +96,9 @@ def fetch(options = {})
       end
 
       topic_fetches = build_topic_fetch_request(fetch_max_bytes)
+      p "PRE FETCH: #{Time.now.to_i}"
       fetch_response = @connection.fetch(fetch_max_wait, fetch_min_bytes, topic_fetches)
+      p "POST FETCH: #{Time.now.to_i}"
       topic_response = fetch_response.topic_fetch_responses.first 
       partition_response = topic_response.partition_fetch_responses.first
 

script/cibuild

@@ -0,0 +1,2 @@
+#!/bin/sh
+bundle exec rake spec:all

spec/integration/simple/spec_helper.rb

@@ -8,7 +8,7 @@
     JavaRunner.set_kafka_path!
     $tc = TestCluster.new
     $tc.start
-    sleep 5
+    sleep 10
   end
 
   config.after(:each) do

spec/setup_kafka.sh

@@ -0,0 +1,8 @@
+#!/bin/sh
+
+cd spec/
+
+git clone https://github.com/apache/kafka.git
+cd kafka
+git checkout 0.8.1
+./gradlew -q jar

spec/test_cluster.rb

@@ -60,12 +60,13 @@ def stop
     if !@stopped
       killed_at = Time.now
       loop do
+        puts `ps ax | grep java`
         if (pid = `#{@pid_cmd}`.to_i) == 0
           SPEC_LOGGER.info "Killed."
           break
         end
 
-        if Time.now - killed_at > 30
+        if Time.now - killed_at > 60
           raise "Failed to kill process!"
         end
 
@@ -94,7 +95,7 @@ def without_process
 
   def run
     FileUtils.mkdir_p(log_dir)
-    `LOG_DIR=#{log_dir} #{@start_cmd} #{config_path}`
+    system( { "LOG_DIR" => log_dir }, "#{@start_cmd} #{config_path}")
     @stopped = false
   end