Update README and source.clj to set default error-skip-offset-amount to 0

Author: yblanke

README.md

@@ -85,7 +85,7 @@ Note: `int` is used for brevity but can also mean `long`. Don't worry about it.
 | :shape                                | `:value:`, `[:vector <fields>]`,`[:map <fields>]`, or an arity-1 function of `ConsumerRecord` | optional | If unspecified, channel will contain ConsumerRecord objects. [Examples](#data-shapes)                                                                                      |
 | :ketu.source/consumer-decorator       | `ConsumerDecorator`                                                                           | optional | [Protocol](#ketu.decorators.consumer.protocol)                                                                                                                             |
 | :ketu.source/poll-error-handler       | `(fn [^Consumer consumer opts] ...)`                                                          | optional | Called when `poll` throws (non-wakeup) exception; should return a (possibly empty) collection of records. May mutate consumer (e.g. `seek`) and/or opts (consumer options) |
-| :ketu.source/error-skip-offset-amount | int                                                                                           | optional | Number of records to skip on a poll exception. If not set, default value is 1.                                                                                             |
+| :ketu.source/error-skip-offset-amount | int                                                                                           | optional | Number of records to skip on a poll exception. Default `0` (no offset change).                                                                                             |
 
 #### Producer-sink options
 

src/ketu/async/source.clj

@@ -44,7 +44,8 @@
    :ketu.source/consumer-close-timeout-ms  60000
    :ketu.source/consumer-thread-timeout-ms 60000
    :ketu.source/close-out-chan?            true
-   :ketu.source/close-consumer?            true})
+   :ketu.source/close-consumer?            true
+   :ketu.source/error-skip-offset-amount   0})
 
 (defn- finalize-opts [opts]
   (-> (default-opts)
@@ -75,13 +76,13 @@
       (fn [consumer]
         (consumer/assign! consumer (consumer/topic-partitions topic partitions))))))
 
-(defn- increment-offsets-for-assigned-partitions!
+(defn increment-offsets-for-assigned-partitions!
   "Increments the offset by records-to-skip for all assigned partitions to skip faulty messages.
-  If records-to-skip is not provided, default to 1."
+  Default skip amount is 0 (no offset change)."
   ([^Consumer consumer source-name records-to-skip]
    (try
      (let [assigned-partitions (consumer/assignment consumer)
-           skip-amount         (or records-to-skip 1)]
+           skip-amount         records-to-skip]
        (doseq [^TopicPartition partition assigned-partitions]
          (try
            (let [current-position (consumer/position consumer partition)