Merge pull request influxdata#1930 from influxdata/aa_kafka_1927

added default as name for the default kafka config
ops-itop · May 17, 2018 · 49d8eab · 49d8eab
2 parents 18e4ce7 + 7d40d2f
commit 49d8eab
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/services/kafka/config.go b/services/kafka/config.go
@@ -14,6 +14,7 @@ const (
 	DefaultTimeout      = 10 * time.Second
 	DefaultBatchSize    = 100
 	DefaultBatchTimeout = 1 * time.Second
+	DefaultID           = "default"
 )
 
 type Config struct {
@@ -45,7 +46,7 @@ type Config struct {
 }
 
 func NewConfig() Config {
-	return Config{}
+	return Config{ID: DefaultID}
 }
 
 func (c Config) Validate() error {