'Version 1.5.4 of the DynamoDB Streams Kinesis Adapter'

README.md

@@ -14,11 +14,16 @@
 * The KCL is designed to process streams from Amazon Kinesis, but by adding the DynamoDB Streams Kinesis Adapter, your application can process DynamoDB Streams instead, seamlessly and efficiently.
 
 ## Release Notes
-### Latest Release (v1.5.3)
+### Latest Release (v1.5.4)
+* Upgrades AWS Java SDK to version 1.12.130
+* Upgrades jackson-databind to version 2.12.6.1
+* Fixes logging in `DynamoDBStreamsShardSyncer` to log only the problematic shardId instead of logging all the shardIds
+
+
+### Release (v1.5.3)
 * Upgrades jackson-databind to version 2.9.10.7
 * Upgrades junit to version 4.13.1
 * Upgrades AWS Java SDK to version 1.11.1016
-* Implements `MillisBehindLatest` metric that measures the age of the last processed record per stream-shard in milliseconds.
 
 ### Release (v1.5.2)
 * Upgrades jackson-databind to version 2.9.10.5

pom.xml

@@ -6,7 +6,7 @@
  <artifactId>dynamodb-streams-kinesis-adapter</artifactId>
  <packaging>jar</packaging>
  <name>DynamoDB Streams Adapter for Java</name>
- <version>1.5.3</version>
+ <version>1.5.4</version>
  <description>The DynamoDB Streams Adapter implements the AmazonKinesis interface so that your application can use KCL to consume and process data from a DynamoDB stream.</description>
  <url>https://aws.amazon.com/dynamodb</url>
 
@@ -23,7 +23,7 @@
  </licenses>
 
  <properties>
- <aws-java-sdk.version>1.11.1016</aws-java-sdk.version>
+ <aws-java-sdk.version>1.12.130</aws-java-sdk.version>
  <amazon-kinesis-client.version>1.13.3</amazon-kinesis-client.version>
  <powermock.version>1.6.2</powermock.version>
  <aws.dynamodblocal.version>[1.12,2.0)</aws.dynamodblocal.version>
@@ -62,7 +62,7 @@
  <dependency>
  <groupId>com.fasterxml.jackson.core</groupId>
  <artifactId>jackson-databind</artifactId>
- <version>2.9.10.7</version>
+ <version>2.12.6.1</version>
  </dependency>
 
  <dependency>

src/main/java/com/amazonaws/services/dynamodbv2/streamsadapter/DynamoDBStreamsShardSyncer.java

@@ -234,7 +234,7 @@ synchronized void assertClosedShardsAreCoveredOrAbsent(Map<String, Shard> shardI
 
  String endingSequenceNumber = shard.getSequenceNumberRange().getEndingSequenceNumber();
  if (endingSequenceNumber == null) {
- throw new KinesisClientLibIOException("Shard " + shardIdsOfClosedShards
+ throw new KinesisClientLibIOException("Shard " + shardId
  + " is not closed. " + exceptionMessageSuffix);
  }