Don't check the continuation sequence number if it's null (#426)

Would cause shard end handling to fail. Also advanced the version
awslabs · Sep 27, 2018 · f3b0dad · f3b0dad
1 parent 47dcfdb
commit f3b0dad
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 8 deletions.
diff --git a/amazon-kinesis-client-multilang/pom.xml b/amazon-kinesis-client-multilang/pom.xml
@@ -19,7 +19,7 @@
   <parent>
     <artifactId>amazon-kinesis-client-pom</artifactId>
     <groupId>software.amazon.kinesis</groupId>
-    <version>2.0.3-experimental-6</version>
+    <version>2.0.3-experimental-7</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

diff --git a/amazon-kinesis-client/pom.xml b/amazon-kinesis-client/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <groupId>software.amazon.kinesis</groupId>
     <artifactId>amazon-kinesis-client-pom</artifactId>
-    <version>2.0.3-experimental-6</version>
+    <version>2.0.3-experimental-7</version>
   </parent>
 
   <artifactId>amazon-kinesis-client</artifactId>

diff --git a/...ware/amazon/kinesis/retrieval/fanout/experimental/ExperimentalFanOutRecordsPublisher.java b/...ware/amazon/kinesis/retrieval/fanout/experimental/ExperimentalFanOutRecordsPublisher.java
@@ -62,11 +62,13 @@ protected void validateRecords(String shardId, SubscribeToShardEvent event) {
             throw new IllegalArgumentException(mismatchReport);
         }
 
-        Map<String, Integer> continuationMismatch = mismatchedRecordReporter.recordsNotForShard(shardId, Stream.of(event.continuationSequenceNumber()));
-        if (!continuationMismatch.isEmpty()) {
-            String continuationReport = "Continuation sequence number not matched to shard: " + mismatchedRecordReporter.makeReport(continuationMismatch);
-            log.error(continuationReport);
-            throw new IllegalArgumentException(continuationReport);
+        if (event.continuationSequenceNumber() != null) {
+            Map<String, Integer> continuationMismatch = mismatchedRecordReporter.recordsNotForShard(shardId, Stream.of(event.continuationSequenceNumber()));
+            if (!continuationMismatch.isEmpty()) {
+                String continuationReport = "Continuation sequence number not matched to shard: " + mismatchedRecordReporter.makeReport(continuationMismatch);
+                log.error(continuationReport);
+                throw new IllegalArgumentException(continuationReport);
+            }
         }
 
     }

diff --git a/pom.xml b/pom.xml
@@ -20,7 +20,7 @@
   <artifactId>amazon-kinesis-client-pom</artifactId>
   <packaging>pom</packaging>
   <name>Amazon Kinesis Client Library</name>
-  <version>2.0.3-experimental-6</version>
+  <version>2.0.3-experimental-7</version>
   <description>The Amazon Kinesis Client Library for Java enables Java developers to easily consume and process data
     from Amazon Kinesis.
   </description>