Merge pull request #572 from Shopify/kafka09

Add kafka 0.9

.travis.yml

@@ -13,6 +13,7 @@ env:
   matrix:
   - KAFKA_VERSION=0.8.1.1
   - KAFKA_VERSION=0.8.2.2
+  - KAFKA_VERSION=0.9.0.0
 
 before_install:
 - export REPOSITORY_ROOT=${TRAVIS_BUILD_DIR}

functional_offset_manager_test.go

@@ -1,11 +1,16 @@
 package sarama
 
 import (
+	"os"
 	"testing"
 )
 
 func TestFuncOffsetManager(t *testing.T) {
 	checkKafkaVersion(t, "0.8.2")
+	if os.Getenv("KAFKA_VERSION") == "0.9.0.0" {
+		t.Skip("Offset manager is broken with kafka 0.9 at the moment.")
+	}
+
 	setupFunctionalTest(t)
 	defer teardownFunctionalTest(t)
 

functional_test.go

@@ -129,6 +129,8 @@ func (kv kafkaVersion) satisfies(other kafkaVersion) bool {
 
 		if v < ov {
 			return false
+		} else if v > ov {
+			return true
 		}
 	}
 	return true

vagrant/provision.sh

@@ -7,7 +7,7 @@ yes | apt-get install default-jre
 
 export KAFKA_INSTALL_ROOT=/opt
 export KAFKA_HOSTNAME=192.168.100.67
-export KAFKA_VERSION=0.8.2.2
+export KAFKA_VERSION=0.9.0.0
 export REPOSITORY_ROOT=/vagrant
 
 sh /vagrant/vagrant/install_cluster.sh

vagrant/server.properties

@@ -18,6 +18,7 @@
 
 # The id of the broker. This must be set to a unique integer for each broker.
 broker.id=KAFKAID
+reserved.broker.max.id=10000
 
 ############################# Socket Server Settings #############################