kinetic.consumer — com.tolitius/kinetic 0.1.5

->record clj

(->record record)

delete-all-leases clj

(delete-all-leases scheduler)

delete-lease clj

(delete-lease scheduler lease)

delete-leases-for-stream clj

(delete-leases-for-stream scheduler stream)

echo clj

(echo records)

echo consume function. expects records to be UTF-8 decoded

find-leases-for-stream clj

(find-leases-for-stream scheduler stream)

make-config clj

(make-config {:keys [streams multi-stream? aws-account-number application-name
                     kinesis-client dynamo-client cloud-watch-client
                     record-processor-factory]
              :as opts})

make-lease clj

(make-lease lease-key)

make-scheduler clj

(make-scheduler {:keys [config-builder polling-config]})

make-utf8-decoder clj

(make-utf8-decoder)

prep-initial-position clj

(prep-initial-position scheduler
                       aws-account-number
                       {:keys [start-from delete-leases?] :as stream})

if there is an existing lease, by default, kinesis client will ignore an initial position that is provided. this deletes existing leases for this app (a.k.a. consumer group) in case there is a position provided

record-checkpoint clj

(record-checkpoint checkpointer)

shard-record-processor clj

(shard-record-processor consume checkpoint-every-ms)

shard-record-processor-factory clj

(shard-record-processor-factory consume checkpoint-every-ms)

show-leases clj

(show-leases consumer)

start-consumer clj

(start-consumer {:keys [application-name aws-account-number streams creds region
                        consume checkpoint-every-ms config]
                 :as opts})

stop-consumer clj

(stop-consumer {:keys [scheduler executor]})

validate-consumer-args clj

(validate-consumer-args {:keys [stream-name application-name consume] :as args})