From 1269ff9eca55b67cd6e3e1b892c2356317eba493 Mon Sep 17 00:00:00 2001 From: andronache Date: Fri, 26 Feb 2021 16:59:58 +0200 Subject: [PATCH] Tests in ers --- ers/kafka_it_test.go | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/ers/kafka_it_test.go b/ers/kafka_it_test.go index 9948ea566..6c710f587 100644 --- a/ers/kafka_it_test.go +++ b/ers/kafka_it_test.go @@ -20,6 +20,19 @@ along with this program. If not, see package ers +import ( + "context" + "fmt" + "reflect" + "testing" + "time" + + "github.com/cgrates/cgrates/config" + "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" + kafka "github.com/segmentio/kafka-go" +) + var ( rdrEvents chan *erEvent rdrErr chan error @@ -27,7 +40,6 @@ var ( rdr EventReader ) -/* func TestKafkaER(t *testing.T) { cfg, err := config.NewCGRConfigFromJSONStringWithDefaults(`{ "ers": { // EventReaderService @@ -103,4 +115,3 @@ func TestKafkaER(t *testing.T) { } close(rdrExit) } -*/