Add support for Kafka 0.11, leaving 0.10.2 as default

linkedin · Dec 4, 2017 · f4f35f2 · f4f35f2
1 parent fdf5ce6
commit f4f35f2
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/core/internal/helpers/sarama.go b/core/internal/helpers/sarama.go
@@ -40,6 +40,8 @@ func parseKafkaVersion(kafkaVersion string) sarama.KafkaVersion {
 		return sarama.V0_10_1_0
 	case "", "0.10.2", "0.10.2.0":
 		return sarama.V0_10_2_0
+	case "0.11.0", "0.11.0.1", "0.11.0.2":
+		return sarama.V0_11_0_0
 	default:
 		panic("Unknown Kafka Version: " + kafkaVersion)
 	}