Updated KCL to 1.9.3

amazon-archives · Jan 10, 2019 · 8429d03 · 8429d03
1 parent 13e4140
commit 8429d03
Show file tree

Hide file tree

Showing 2 changed files with 48 additions and 6 deletions.
diff --git a/pom.xml b/pom.xml
@@ -6,7 +6,7 @@
     <artifactId>amazon-kinesis-connectors</artifactId>
     <packaging>jar</packaging>
     <name>Amazon Kinesis Connector Library</name>
-    <version>1.3.0</version>
+    <version>1.4.0</version>
     <description>The Amazon Kinesis Connector Library helps Java developers integrate Amazon Kinesis with other AWS and non-AWS services.</description>
     <url>https://aws.amazon.com/kinesis</url>
 
@@ -23,10 +23,11 @@
     </licenses>
 
     <properties>
-        <amazon-kinesis-client.version>1.7.2</amazon-kinesis-client.version>
-        <aws-java-sdk.version>1.11.14</aws-java-sdk.version>
+        <amazon-kinesis-client.version>1.9.0</amazon-kinesis-client.version>
+        <aws-java-sdk.version>1.11.438</aws-java-sdk.version>
         <elasticsearch.version>1.2.1</elasticsearch.version>
         <fasterxml-jackson.version>2.6.6</fasterxml-jackson.version>
+        <maven.enforcer.plugin.version>3.0.0-M2</maven.enforcer.plugin.version>
     </properties>
 
     <dependencies>
@@ -131,10 +132,26 @@
                         <encoding>UTF-8</encoding>
                     </configuration>
                 </plugin>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-enforcer-plugin</artifactId>
+                    <version>${maven.enforcer.plugin.version}</version>
+                    <executions>
+                        <execution>
+                            <id>enforce</id>
+                            <configuration>
+                                <rules>
+                                    <dependencyConvergence/>
+                                </rules>
+                            </configuration>
+                            <goals>
+                                <goal>enforce</goal>
+                            </goals>
+                        </execution>
+                    </executions>
+                </plugin>
             </plugins>
         </pluginManagement>
-
-
     </build>
 
     <profiles>
@@ -145,7 +162,7 @@
                     <plugin>
                         <groupId>org.apache.maven.plugins</groupId>
                         <artifactId>maven-gpg-plugin</artifactId>
-                        <version>1.5</version>
+                        <version>1.6</version>
                         <executions>
                             <execution>
                                 <id>sign-artifacts</id>

diff --git a/...m/amazonaws/services/kinesis/connectors/KinesisClientLibraryPipelinedRecordProcessor.java b/...m/amazonaws/services/kinesis/connectors/KinesisClientLibraryPipelinedRecordProcessor.java
@@ -22,6 +22,7 @@
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
 
+import com.amazonaws.services.kinesis.clientlibrary.interfaces.IPreparedCheckpointer;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -267,6 +268,30 @@ public void checkpoint(String sequenceNumber, long subSequenceNumber) throws Kin
                     InvalidStateException, ThrottlingException, ShutdownException, IllegalArgumentException {
                 throw new UnsupportedOperationException();
             }
+
+            @Override
+            public IPreparedCheckpointer prepareCheckpoint() throws KinesisClientLibDependencyException,
+                    InvalidStateException, ThrottlingException, ShutdownException {
+                throw new UnsupportedOperationException();
+            }
+
+            @Override
+            public IPreparedCheckpointer prepareCheckpoint(Record record) throws KinesisClientLibDependencyException,
+                    InvalidStateException, ThrottlingException, ShutdownException {
+                throw new UnsupportedOperationException();
+            }
+
+            @Override
+            public IPreparedCheckpointer prepareCheckpoint(String s) throws KinesisClientLibDependencyException,
+                    InvalidStateException, ThrottlingException, ShutdownException, IllegalArgumentException {
+                return internalCheckpointer.prepareCheckpoint(s);
+            }
+
+            @Override
+            public IPreparedCheckpointer prepareCheckpoint(String s, long l) throws KinesisClientLibDependencyException,
+                    InvalidStateException, ThrottlingException, ShutdownException, IllegalArgumentException {
+                throw new UnsupportedOperationException();
+            }
         };
     }
 }