kinetic.consumer — com.tolitius/kinetic 0.1.0

->record clj

(->record record)

delete-all-leases clj

(delete-all-leases {:keys [scheduler]})

echo clj

(echo records)

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

make-config clj

(make-config {:keys [stream-name start-from application-name kinesis-client
                     dynamo-client cloud-watch-client record-processor-factory]
              :as opts})

make-initial-position clj

(make-initial-position {:keys [position timestamp] :as at})

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 start-from delete-leases?)

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)

single-stream-tracker clj

(single-stream-tracker {:keys [stream-name start-from]})

start-consumer clj

(start-consumer {:keys [stream-name application-name region consume start-from
                        delete-leases? checkpoint-every-ms config]
                 :or {delete-leases? true}
                 :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})