diff --git a/localstack/services/kinesis/packages.py b/localstack/services/kinesis/packages.py
index 07320dff39dfd..b3e3528b05e3e 100644
--- a/localstack/services/kinesis/packages.py
+++ b/localstack/services/kinesis/packages.py
@@ -6,7 +6,7 @@
 from localstack.packages import GitHubReleaseInstaller, Package, PackageInstaller
 from localstack.utils.platform import get_arch, get_os
 
-_KINESIS_MOCK_VERSION = os.environ.get("KINESIS_MOCK_VERSION") or "0.3.4"
+_KINESIS_MOCK_VERSION = os.environ.get("KINESIS_MOCK_VERSION") or "0.3.5"
 
 
 class KinesisMockPackage(Package):
diff --git a/tests/integration/cloudformation/resources/test_kinesis.snapshot.json b/tests/integration/cloudformation/resources/test_kinesis.snapshot.json
index 25aab03f987b3..eee6e67dc661f 100644
--- a/tests/integration/cloudformation/resources/test_kinesis.snapshot.json
+++ b/tests/integration/cloudformation/resources/test_kinesis.snapshot.json
@@ -29,11 +29,6 @@
       "stream_description": {
         "StreamDescription": {
           "EncryptionType": "NONE",
-          "EnhancedMonitoring": [
-            {
-              "ShardLevelMetrics": []
-            }
-          ],
           "HasMoreShards": false,
           "RetentionPeriodHours": 24,
           "Shards": [
@@ -63,4 +58,4 @@
       }
     }
   }
-}
\ No newline at end of file
+}
diff --git a/tests/integration/cloudformation/resources/test_lambda.snapshot.json b/tests/integration/cloudformation/resources/test_lambda.snapshot.json
index 11299cb9db39d..d306b3c8aef11 100644
--- a/tests/integration/cloudformation/resources/test_lambda.snapshot.json
+++ b/tests/integration/cloudformation/resources/test_lambda.snapshot.json
@@ -1228,11 +1228,6 @@
       "describe_stream_result": {
         "StreamDescription": {
           "EncryptionType": "NONE",
-          "EnhancedMonitoring": [
-            {
-              "ShardLevelMetrics": []
-            }
-          ],
           "HasMoreShards": false,
           "RetentionPeriodHours": 24,
           "Shards": [
diff --git a/tests/integration/test_apigateway.py b/tests/integration/test_apigateway.py
index 08786bb2a55c8..7703779d81682 100644
--- a/tests/integration/test_apigateway.py
+++ b/tests/integration/test_apigateway.py
@@ -275,7 +275,7 @@ def test_api_gateway_kinesis_integration(self):
         # post test data to Kinesis via API Gateway
         result = requests.post(url, data=json.dumps(test_data))
         result = json.loads(to_str(result.content))
-        assert 0 == result["FailedRecordCount"]
+        assert result.get("FailedRecordCount") is None
         assert len(test_data["records"]) == len(result["Records"])
 
         # clean up
diff --git a/tests/integration/test_error_injection.py b/tests/integration/test_error_injection.py
index 6ef0de9a007a0..a5902cb3677eb 100644
--- a/tests/integration/test_error_injection.py
+++ b/tests/integration/test_error_injection.py
@@ -22,7 +22,7 @@ def test_kinesis_error_injection(self, monkeypatch, kinesis_client, wait_for_str
 
             # by default, no errors
             test_no_errors = kinesis.put_records(StreamName=stream_name, Records=records)
-            assert test_no_errors["FailedRecordCount"] == 0
+            assert test_no_errors.get("FailedRecordCount") is None
 
             # with a probability of 1, always throw errors
             monkeypatch.setattr(config, "KINESIS_ERROR_PROBABILITY", 1.0)