From 68b2e59226f01229915eabbc6529a421a5335c6d Mon Sep 17 00:00:00 2001
From: Jeremy Custenborder <jcustenborder@gmail.com>
Date: Mon, 2 Apr 2018 19:26:04 -0500
Subject: [PATCH] Issue 42 (#43)

* Added assembly plugin. fixes #42.

* Corrected. Just a sink.
---
 pom.xml                                       | 40 +++++++++++++++++++
 .../spooldir/SpoolDirJsonSourceTask.java      |  2 +-
 2 files changed, 41 insertions(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index aacfd44..b4ddac4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -53,4 +53,44 @@
             <version>3.10</version>
         </dependency>
     </dependencies>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>io.confluent</groupId>
+                <artifactId>kafka-connect-maven-plugin</artifactId>
+                <version>0.9.0</version>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>kafka-connect</goal>
+                        </goals>
+                        <configuration>
+                            <ownerUsername>jcustenborder</ownerUsername>
+                            <confluentControlCenterIntegration>true
+                            </confluentControlCenterIntegration>
+                            <documentationUrl>
+                                https://jcustenborder.github.io/kafka-connect-documentation/
+                            </documentationUrl>
+                            <ownerName>Jeremy Custenborder</ownerName>
+                            <dockerNamespace>jcustenborder</dockerNamespace>
+                            <dockerName>kafka-connect-docker</dockerName>
+                            <pluginTypes>
+                                <pluginType>source</pluginType>
+                            </pluginTypes>
+                            <tags>
+                                <tag>File</tag>
+                                <tag>Flume</tag>
+                                <tag>csv</tag>
+                                <tag>json</tag>
+                            </tags>
+                            <title>Kafka Connect Spooldir</title>
+                            <supportUrl>${pom.issueManagement.url}</supportUrl>
+                            <supportSummary>Support provided through community involvement.
+                            </supportSummary>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
 </project>
diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/spooldir/SpoolDirJsonSourceTask.java b/src/main/java/com/github/jcustenborder/kafka/connect/spooldir/SpoolDirJsonSourceTask.java
index 53128d6..0395d11 100644
--- a/src/main/java/com/github/jcustenborder/kafka/connect/spooldir/SpoolDirJsonSourceTask.java
+++ b/src/main/java/com/github/jcustenborder/kafka/connect/spooldir/SpoolDirJsonSourceTask.java
@@ -60,7 +60,7 @@ protected void configure(InputStream inputStream, Map<String, String> metadata,
     this.offset = -1;
 
     if (null != lastOffset) {
-      int skippedRecords = 0;
+      int skippedRecords = 1;
       while (this.iterator.hasNext() && skippedRecords <= lastOffset) {
         next();
         skippedRecords++;