saved prev records for testing purposes

netobserv · May 1, 2022 · d8a54c1 · d8a54c1
1 parent 9e05c62
commit d8a54c1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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