diff --git a/integration/docker-compose.yml b/integration/docker-compose.yml
index 2850d46f..a1c1d075 100644
--- a/integration/docker-compose.yml
+++ b/integration/docker-compose.yml
@@ -2,11 +2,11 @@ version: "3"
 
 services:
   localstack:
-    image: localstack/localstack-light:0.11.1
+    image: localstack/localstack-light:1.1.0
     ports:
       - "4566-4568:4566-4568"
     volumes:
-      - "./.localstack:/tmp/localstack"
+      - "./.localstack:/var/lib/localstack"
       - "./localstack:/docker-entrypoint-initaws.d"
       - "/var/run/docker.sock:/var/run/docker.sock"
     logging:
@@ -15,7 +15,6 @@ services:
         max-file: "10"
     environment:
       - SERVICES=sqs,kinesis,dynamodb,sts
-      - DATA_DIR=/tmp/localstack/data
 
   pubsub:
     image: bigtruedata/gcloud-pubsub-emulator
diff --git a/pkg/source/sqs/sqs_source_test.go b/pkg/source/sqs/sqs_source_test.go
index 84aa4b77..147079ec 100644
--- a/pkg/source/sqs/sqs_source_test.go
+++ b/pkg/source/sqs/sqs_source_test.go
@@ -84,7 +84,7 @@ func TestSQSSource_ReadFailure(t *testing.T) {
 	err = source.Read(nil)
 	assert.NotNil(err)
 	if err != nil {
-		assert.Equal("Failed to get SQS queue URL: AWS.SimpleQueueService.NonExistentQueue: AWS.SimpleQueueService.NonExistentQueue; see the SQS docs.\n\tstatus code: 400, request id: 00000000-0000-0000-0000-000000000000", err.Error())
+		assert.Contains(err.Error(), "Failed to get SQS queue URL:")
 	}
 }
 
diff --git a/pkg/target/kinesis_test.go b/pkg/target/kinesis_test.go
index fedfad7c..23d752f2 100644
--- a/pkg/target/kinesis_test.go
+++ b/pkg/target/kinesis_test.go
@@ -37,7 +37,7 @@ func TestKinesisTarget_WriteFailure(t *testing.T) {
 	writeRes, err := target.Write(messages)
 	assert.NotNil(err)
 	if err != nil {
-		assert.Equal("Error writing messages to Kinesis stream: 1 error occurred:\n\t* Failed to send message batch to Kinesis stream: ResourceNotFoundException: Stream not-exists under account 000000000000 not found.\n\n", err.Error())
+		assert.Contains(err.Error(), "Error writing messages to Kinesis stream: 1 error occurred:")
 	}
 	assert.NotNil(writeRes)