From 39d451aeefa39cddea77b724267dbfb366fe5753 Mon Sep 17 00:00:00 2001
From: Zack Wine <zwine@synamedia.com>
Date: Fri, 21 Aug 2020 15:02:08 -0400
Subject: [PATCH] Add warning if both aggregation and partition_key are
 enabled.

---
 fluent-bit-kinesis.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/fluent-bit-kinesis.go b/fluent-bit-kinesis.go
index 4ad24bc..fca61ad 100644
--- 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 != "" {