refactor(injector.go): changes parameter from withKeyAndValue to includeKey

João Assunção · João Assunção · commit 33eac22e35f4 · 2020-04-07T13:46:49.000-03:00
diff --git a/cmd/injector.go b/cmd/injector.go
@@ -45,7 +45,7 @@ func main() {
 		BufferSize:            os.Getenv("KAFKA_CONSUMER_BUFFER_SIZE"),
 		MetricsUpdateInterval: os.Getenv("KAFKA_CONSUMER_METRICS_UPDATE_INTERVAL"),
 		RecordType:            os.Getenv("KAFKA_CONSUMER_RECORD_TYPE"),
-		WithKeyAndValue:       os.Getenv("KAFKA_CONSUMER_WITH_KEY_AND_VALUE"),
+		IncludeKey:            os.Getenv("KAFKA_CONSUMER_INCLUDE_KEY"),
 	}
 	metricsPublisher := metrics.NewMetricsPublisher()
 	service := injector.NewService(logger, metricsPublisher)

Original file line number	Diff line number	Diff line change
`@@ -45,7 +45,7 @@ func main() {`
`45`	`45`	`BufferSize: os.Getenv("KAFKA_CONSUMER_BUFFER_SIZE"),`
`46`	`46`	`MetricsUpdateInterval: os.Getenv("KAFKA_CONSUMER_METRICS_UPDATE_INTERVAL"),`
`47`	`47`	`RecordType: os.Getenv("KAFKA_CONSUMER_RECORD_TYPE"),`
`48`		`- WithKeyAndValue: os.Getenv("KAFKA_CONSUMER_WITH_KEY_AND_VALUE"),`
	`48`	`+ IncludeKey: os.Getenv("KAFKA_CONSUMER_INCLUDE_KEY"),`
`49`	`49`	`}`
`50`	`50`	`metricsPublisher := metrics.NewMetricsPublisher()`
`51`	`51`	`service := injector.NewService(logger, metricsPublisher)`