From d36e24307e209e0108e0ecf066d3cc3b6ea3f1ad Mon Sep 17 00:00:00 2001
From: programmer10110 <programmer10110@yandex.ru>
Date: Tue, 24 Nov 2020 14:11:46 +0300
Subject: [PATCH] fix kafka-tests

---
 storage/kafkaStorage_test.go | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git a/storage/kafkaStorage_test.go b/storage/kafkaStorage_test.go
index 84e1836..d773708 100644
--- a/storage/kafkaStorage_test.go
+++ b/storage/kafkaStorage_test.go
@@ -67,8 +67,22 @@ func TestKafkaStorage_SendBatch(t *testing.T) {
 	N := 10
 	var offset uint64 = 5
 
+	producerCreds := &KafkaAuthCredentials{
+		Username: "producer",
+		Password: "producerpass",
+	}
+	consumerCreds := &KafkaAuthCredentials{
+		Username: "consumer",
+		Password: "consumerpass",
+	}
+
+	tlsConfig, err := GetTLSConfig("../kafka-docker/certs/ca.crt")
+	if err != nil {
+		t.Fatal(err.Error())
+	}
+
 	req := require.New(t)
-	stg, err := NewKafkaStorage(context.Background(), "localhost:9092", "test_topic")
+	stg, err := NewKafkaStorage(context.Background(), "localhost:9093", "test", tlsConfig, producerCreds, consumerCreds)
 	req.NoError(err)
 
 	msgs := make([]Message, 0, N)