Add warning if both aggregation and partition_key are enabled.

zhonghui12 · Aug 21, 2020 · 39d451a · 39d451a
1 parent 4f9fb87
commit 39d451a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/fluent-bit-kinesis.go b/fluent-bit-kinesis.go
@@ -108,6 +108,10 @@ func newKinesisOutput(ctx unsafe.Pointer, pluginID int) (*kinesis.OutputPlugin,
 		isAggregate = true
 	}
 
+	if isAggregate && partitionKey != "" {
+		logrus.Errorf("[kinesis %d]  WARNING: The options 'aggregation' and  'partition_key' should not be used in simaltaniously", pluginID)
+	}
+
 	var concurrencyInt, concurrencyRetriesInt int
 	var err error
 	if concurrency != "" {