Apply suggestions from code review

Co-Authored-By: Yuri Shkuro <[email protected]>
jaegertracing · Jan 28, 2020 · 04da10c · 04da10c
1 parent 009d609
commit 04da10c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plugin/storage/kafka/options.go b/plugin/storage/kafka/options.go
@@ -148,12 +148,12 @@ func (opt *Options) AddFlags(flagSet *flag.FlagSet) {
 	flagSet.Int(
 		configPrefix+suffixLingerMS,
 		defaultLingerMS,
-		"(experimental) Number of milliseconds to delay before sending records to Kafka. Higher value reduce request to Kafka but increase latency.",
+		"(experimental) Number of milliseconds to delay before sending records to Kafka. Higher value reduce request volume to Kafka but increase latency and the possibility of data loss in case of process restart.",
 	)
 	flagSet.Int(
 		configPrefix+suffixBatchSize,
 		defaultBatchSize,
-		"(experimental) Number of bytes to batch before sending records to Kafka. Higher value reduce request to Kafka but increase latency.",
+		"(experimental) Number of bytes to batch before sending records to Kafka. Higher value reduce request volume to Kafka but increase latency and the possibility of data loss in case of process restart.",
 	)
 	auth.AddFlags(configPrefix, flagSet)
 }