rename CreateDefaultConfig as NewConfig

lovoo · Feb 23, 2018 · 624f1f5 · 624f1f5
1 parent 2d57eae
commit 624f1f5
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/kafka/builders.go b/kafka/builders.go
@@ -12,7 +12,7 @@ type ConsumerBuilder func(brokers []string, group, clientID string) (Consumer, e
 
 // DefaultConsumerBuilder creates a Kafka consumer using the Sarama library.
 func DefaultConsumerBuilder(brokers []string, group, clientID string) (Consumer, error) {
-	config := CreateDefaultConfig(clientID)
+	config := NewConfig(clientID)
 	return NewSaramaConsumer(brokers, group, config)
 }
 
@@ -29,7 +29,7 @@ type ProducerBuilder func(brokers []string, clientID string, hasher func() hash.
 
 // DefaultProducerBuilder creates a Kafka producer using the Sarama library.
 func DefaultProducerBuilder(brokers []string, clientID string, hasher func() hash.Hash32) (Producer, error) {
-	config := CreateDefaultConfig(clientID)
+	config := NewConfig(clientID)
 	config.Producer.Partitioner = sarama.NewCustomHashPartitioner(hasher)
 	return NewProducer(brokers, &config.Config)
 }

diff --git a/kafka/config.go b/kafka/config.go
@@ -5,8 +5,8 @@ import (
 	cluster "github.com/bsm/sarama-cluster"
 )
 
-// CreateDefaultConfig creates a (bsm) sarama configuration with default values.
-func CreateDefaultConfig(clientID string) *cluster.Config {
+// NewConfig creates a (bsm) sarama configuration with default values.
+func NewConfig(clientID string) *cluster.Config {
 	config := cluster.NewConfig()
 
 	config.Version = sarama.V0_10_1_0