feat: rebase onto trustpilot/kafka-connect-dynamodb@master (#10)

* Remove deploy step (#13)

Deploys use the GitHub Releases provider. These releases should be created manually. Discussed internally with Emilio.

Co-authored-by: Max Manders <[email protected]>

* Upgrade lo4j (#14)

* Table whitelist config parameter

integration tests

- updated kinesis adapter
- service endpoints config
- fixed credential config types

updated kinesis-adapter

use gson only

integration test task

test switch from init sync

table whitelist config parameter

kcl.table.billing.mode config parameter

add aws-java-sdk-sts dependency

trustpilot#5

params

cleaning

cleanup

docs

* fix for security vunrability move to log4j 2.15.0

Co-authored-by: Raimondas Tijūnaitis <[email protected]>
Co-authored-by: anl-trustpilot <[email protected]>
Co-authored-by: anl-trustpilot <[email protected]>

* Updates log4j to version 2.17.1 (trustpilot#15)

Co-authored-by: Emilio Larrambebere <[email protected]>

* Update_package_versions (trustpilot#21)

* update kcl and dynamo packages

* add dist property to travis file

* override abstract CW  methods

Co-authored-by: fal-trustpilot <[email protected]>

---------

Co-authored-by: Trustpilot Robot User <[email protected]>
Co-authored-by: Max Manders <[email protected]>
Co-authored-by: Raimondas Tijūnaitis <[email protected]>
Co-authored-by: anl-trustpilot <[email protected]>
Co-authored-by: anl-trustpilot <[email protected]>
Co-authored-by: Emilio Larrambebere <[email protected]>
Co-authored-by: fal-trustpilot <[email protected]>

Author: 7 people

.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

@@ -6,7 +6,7 @@ dependencies {
     implementation 'com.fasterxml.jackson.core:jackson-databind:2.15.2'
 
     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;