diff --git a/storage/kafkaStorage_test.go b/storage/kafkaStorage_test.go
index 87ae4b3..2a14d67 100644
--- a/storage/kafkaStorage_test.go
+++ b/storage/kafkaStorage_test.go
@@ -67,7 +67,6 @@ func TestKafkaStorage_SendBatch(t *testing.T) {
 	N := 10
 	var offset uint64 = 5
 
-	req := require.New(t)
 	producerCreds := &KafkaAuthCredentials{
 		Username: "producer",
 		Password: "producerpass",
@@ -82,6 +81,7 @@ func TestKafkaStorage_SendBatch(t *testing.T) {
 		t.Fatal(err.Error())
 	}
 
+	req := require.New(t)
 	stg, err := NewKafkaStorage(context.Background(), "localhost:9093", "test", tlsConfig, producerCreds, consumerCreds)
 	req.NoError(err)
 
@@ -107,4 +107,4 @@ func TestKafkaStorage_SendBatch(t *testing.T) {
 	for idx, msg := range expectedOffsetMsgs {
 		req.Equal(msg.Signature, offsetMsgs[idx].Signature)
 	}
-}
+}
\ No newline at end of file