feat: rebase onto trustpilot/kafka-connect-dynamodb@master

.travis.yml

@@ -1,3 +1,4 @@
+dist: focal
 language: java
 
 before_cache:
@@ -10,11 +11,3 @@ cache:
 script:
   - ./gradlew build --build-cache -PwarningsAsErrors=true
   - ./gradlew shadowJar
-
-deploy:
-  provider: releases
-  api_key: "$GITHUB_TOKEN"
-  file: "build/libs/kafka-connect-dynamodb-${TRAVIS_TAG}.jar"
-  skip_cleanup: true
-  on:
-    tags: true

build.gradle

@@ -59,9 +59,9 @@ allprojects {
         testCompile "com.google.code.gson:gson:2.8.6"
 
         testCompile group: 'org.mockito', name: 'mockito-junit-jupiter', version: '2.26.0'
-        compile group: 'org.apache.logging.log4j', name: 'log4j-api', version: '2.11.2'
-        compile group: 'org.apache.logging.log4j', name: 'log4j-core', version: '2.11.2'
-        compile group: 'org.apache.logging.log4j', name: 'log4j-slf4j-impl', version: '2.11.2'
+        compile group: 'org.apache.logging.log4j', name: 'log4j-api', version: '2.17.1'
+        compile group: 'org.apache.logging.log4j', name: 'log4j-core', version: '2.17.1'
+        compile group: 'org.apache.logging.log4j', name: 'log4j-slf4j-impl', version: '2.17.1'
     }
 
     test {

source/build.gradle

@@ -5,7 +5,7 @@ dependencies {
     implementation 'com.amazonaws:aws-java-sdk-resourcegroupstaggingapi:1.11.551'
 
     compile group: 'org.apache.kafka', name: 'connect-api', version: "${rootProject.ext.kafkaConnectApiVersion}"
-    compile group: 'com.amazonaws', name: 'amazon-kinesis-client', version: '1.9.1'
-    compile group: 'com.amazonaws', name: 'dynamodb-streams-kinesis-adapter', version: '1.5.2'
+    compile group: 'com.amazonaws', name: 'amazon-kinesis-client', version: '1.13.3'
+    compile group: 'com.amazonaws', name: 'dynamodb-streams-kinesis-adapter', version: '1.5.3'
     compile group: 'com.amazonaws', name: 'aws-java-sdk-sts', version: '1.11.877'
 }

source/src/main/java/com/trustpilot/connector/dynamodb/kcl/KclNoopCloudWatch.java

@@ -94,6 +94,11 @@ public GetMetricStatisticsResult getMetricStatistics(GetMetricStatisticsRequest
         return null;
     }
 
+    @Override
+    public GetMetricStreamResult getMetricStream(GetMetricStreamRequest getMetricStreamRequest) {
+        return null;
+    }
+
     @Override
     public GetMetricWidgetImageResult getMetricWidgetImage(GetMetricWidgetImageRequest getMetricWidgetImageRequest) {
         return null;
@@ -119,6 +124,11 @@ public PutAnomalyDetectorResult putAnomalyDetector(PutAnomalyDetectorRequest put
         return null;
     }
 
+    @Override
+    public PutCompositeAlarmResult putCompositeAlarm(PutCompositeAlarmRequest putCompositeAlarmRequest) {
+        return null;
+    }
+
     @Override
     public PutMetricAlarmResult putMetricAlarm(PutMetricAlarmRequest putMetricAlarmRequest) {
         return null;
@@ -129,11 +139,26 @@ public PutMetricDataResult putMetricData(PutMetricDataRequest putMetricDataReque
         return null;
     }
 
+    @Override
+    public PutMetricStreamResult putMetricStream(PutMetricStreamRequest putMetricStreamRequest) {
+        return null;
+    }
+
     @Override
     public SetAlarmStateResult setAlarmState(SetAlarmStateRequest setAlarmStateRequest) {
         return null;
     }
 
+    @Override
+    public StartMetricStreamsResult startMetricStreams(StartMetricStreamsRequest startMetricStreamsRequest) {
+        return null;
+    }
+
+    @Override
+    public StopMetricStreamsResult stopMetricStreams(StopMetricStreamsRequest stopMetricStreamsRequest) {
+        return null;
+    }
+
     @Override
     public TagResourceResult tagResource(TagResourceRequest tagResourceRequest) {
         return null;
@@ -169,6 +194,11 @@ public DeleteInsightRulesResult deleteInsightRules(DeleteInsightRulesRequest del
         return null;
     }
 
+    @Override
+    public DeleteMetricStreamResult deleteMetricStream(DeleteMetricStreamRequest deleteMetricStreamRequest) {
+        return null;
+    }
+
     @Override
     public GetDashboardResult getDashboard(GetDashboardRequest getDashboardRequest) {
         return null;
@@ -189,6 +219,11 @@ public ListDashboardsResult listDashboards(ListDashboardsRequest listDashboardsR
         return null;
     }
 
+    @Override
+    public ListMetricStreamsResult listMetricStreams(ListMetricStreamsRequest listMetricStreamsRequest) {
+        return null;
+    }
+
     @Override
     public PutDashboardResult putDashboard(PutDashboardRequest putDashboardRequest) {
         return null;