diff --git a/plugin/storage/kafka/options.go b/plugin/storage/kafka/options.go
index e608fc1763f..f3763c6c23b 100644
--- 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)
 }