diff --git a/pkg/target/kinesis_test.go b/pkg/target/kinesis_test.go
index e7bfff01..78a45c03 100644
--- a/pkg/target/kinesis_test.go
+++ b/pkg/target/kinesis_test.go
@@ -8,6 +8,10 @@ package target
 
 import (
 	"fmt"
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/credentials"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/kinesis"
 	"strings"
 	"sync/atomic"
 	"testing"
@@ -37,7 +41,12 @@ func TestKinesisTarget_KinesisConnectionFailure(t *testing.T) {
 
 	assert := assert.New(t)
 
-	client := testutil.GetAWSLocalstackKinesisClient()
+	client := kinesis.New(session.Must(session.NewSession(&aws.Config{
+		Credentials:      credentials.NewStaticCredentials("foo", "var", ""),
+		S3ForcePathStyle: aws.Bool(true),
+		Region:           aws.String(`wrong-region`),
+		Endpoint:         aws.String(`wrong-endpoint`),
+	})))
 
 	target, err := newKinesisTargetWithInterfaces(client, "00000000000", testutil.AWSLocalstackRegion, "not-exists")
 	assert.NotNil(err)