From 04da10ceadf59af59a319278186ccd6548664a8a Mon Sep 17 00:00:00 2001 From: apm-opentt <49722990+apm-opentt@users.noreply.github.com> Date: Tue, 28 Jan 2020 13:03:14 -0500 Subject: [PATCH] Apply suggestions from code review Co-Authored-By: Yuri Shkuro --- plugin/storage/kafka/options.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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) }