kinematics.consumer — kinematics 0.2.0

checkpoint! clj

(checkpoint! checkpointer)

Checkpoint logic modeled after https://github.com/aws/aws-sdk-java/blob/master/src/samples/AmazonKinesis/AmazonKinesisApplicationSampleRecordProcessor.java

checkpoint-retries clj

config clj

(config app-name
        stream
        {:keys [kinesis-credential-provider dynamodb-credential-provider
                cloudwatch-credential-provider credential-provider id]
         :as opts})

exp-wait clj

(exp-wait n base max-wait)

Sleeps according to exp-wait-ms

start! clj

(start! worker)

stop! clj

(stop! worker)

worker clj

(worker handler
        app-name
        stream
        {:keys [init-fn shutdown-fn credential-provider] :as opts})

Creates a kinesis worker and IRecordProcessorFactory instance

worker-id clj

(worker-id)

(worker-id ip-address)