From d8a54c1cd8e14d0f795ea81ed75d312ab9aca3ff Mon Sep 17 00:00:00 2001
From: Kalman Meth <meth@il.ibm.com>
Date: Sun, 1 May 2022 11:42:28 +0300
Subject: [PATCH] saved prev records for testing purposes

---
 pkg/pipeline/encode/encode_kafka.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pkg/pipeline/encode/encode_kafka.go b/pkg/pipeline/encode/encode_kafka.go
index fb587684c..5d1d635a2 100644
--- a/pkg/pipeline/encode/encode_kafka.go
+++ b/pkg/pipeline/encode/encode_kafka.go
@@ -40,6 +40,7 @@ type kafkaWriteMessage interface {
 type encodeKafka struct {
 	kafkaParams api.EncodeKafka
 	kafkaWriter kafkaWriteMessage
+	prevRecords []config.GenericMap
 }
 
 // Encode writes entries to kafka topic
@@ -59,6 +60,7 @@ func (r *encodeKafka) Encode(in []config.GenericMap) {
 	if err != nil {
 		log.Errorf("encodeKafka error: %v", err)
 	}
+	r.prevRecords = in
 }
 
 // NewEncodeKafka create a new writer to kafka