diff --git a/kafka/configuration.go b/kafka/configuration.go
index 7f219a4..d17df57 100644
--- a/kafka/configuration.go
+++ b/kafka/configuration.go
@@ -47,7 +47,6 @@ type BrokerConfiguration struct {
 // SaramaConfigFromBrokerConfig returns a Config struct from broker.Configuration parameters
 func SaramaConfigFromBrokerConfig(cfg *BrokerConfiguration) (*sarama.Config, error) {
 	saramaConfig := sarama.NewConfig()
-	saramaConfig.Version = sarama.V0_10_2_0
 
 	if cfg.Timeout > 0 {
 		saramaConfig.Net.DialTimeout = cfg.Timeout
diff --git a/kafka/configuration_test.go b/kafka/configuration_test.go
index ea2bb5e..5974707 100644
--- a/kafka/configuration_test.go
+++ b/kafka/configuration_test.go
@@ -27,16 +27,14 @@ import (
 
 func TestSaramaConfigFromBrokerConfig(t *testing.T) {
 	cfg := kafka.BrokerConfiguration{}
-	saramaConfig, err := kafka.SaramaConfigFromBrokerConfig(&cfg)
+	_, err := kafka.SaramaConfigFromBrokerConfig(&cfg)
 	helpers.FailOnError(t, err)
-	assert.Equal(t, sarama.V0_10_2_0, saramaConfig.Version)
 
 	cfg = kafka.BrokerConfiguration{
 		Timeout: time.Second,
 	}
-	saramaConfig, err = kafka.SaramaConfigFromBrokerConfig(&cfg)
+	saramaConfig, err := kafka.SaramaConfigFromBrokerConfig(&cfg)
 	helpers.FailOnError(t, err)
-	assert.Equal(t, sarama.V0_10_2_0, saramaConfig.Version)
 	assert.Equal(t, time.Second, saramaConfig.Net.DialTimeout)
 	assert.Equal(t, time.Second, saramaConfig.Net.ReadTimeout)
 	assert.Equal(t, time.Second, saramaConfig.Net.WriteTimeout)
@@ -48,7 +46,6 @@ func TestSaramaConfigFromBrokerConfig(t *testing.T) {
 
 	saramaConfig, err = kafka.SaramaConfigFromBrokerConfig(&cfg)
 	helpers.FailOnError(t, err)
-	assert.Equal(t, sarama.V0_10_2_0, saramaConfig.Version)
 	assert.True(t, saramaConfig.Net.TLS.Enable)
 
 	cfg = kafka.BrokerConfiguration{
@@ -60,7 +57,6 @@ func TestSaramaConfigFromBrokerConfig(t *testing.T) {
 	}
 	saramaConfig, err = kafka.SaramaConfigFromBrokerConfig(&cfg)
 	helpers.FailOnError(t, err)
-	assert.Equal(t, sarama.V0_10_2_0, saramaConfig.Version)
 	assert.True(t, saramaConfig.Net.TLS.Enable)
 	assert.True(t, saramaConfig.Net.SASL.Enable)
 	assert.Equal(t, sarama.SASLMechanism("PLAIN"), saramaConfig.Net.SASL.Mechanism)
@@ -71,7 +67,6 @@ func TestSaramaConfigFromBrokerConfig(t *testing.T) {
 	cfg.SaslMechanism = "SCRAM-SHA-512"
 	saramaConfig, err = kafka.SaramaConfigFromBrokerConfig(&cfg)
 	helpers.FailOnError(t, err)
-	assert.Equal(t, sarama.V0_10_2_0, saramaConfig.Version)
 	assert.True(t, saramaConfig.Net.TLS.Enable)
 	assert.True(t, saramaConfig.Net.SASL.Enable)
 	assert.Equal(t, sarama.SASLMechanism(sarama.SASLTypeSCRAMSHA512), saramaConfig.Net.SASL.Mechanism)