ziggurat.kafka-consumer.consumer-handler — tech.gojek/ziggurat 4.12.0

batch-consumption-metric-ns clj

DEFAULT_POLL_TIMEOUT_MS_CONFIG clj

poll-for-messages clj

(poll-for-messages consumer handler-fn topic-entity consumer-config)

process clj

(process batch-handler batch-payload)

validate-batch-processing-result clj

(validate-batch-processing-result result)

validate-return-type clj

(validate-return-type result)