ventas.kafka.consumer — ventas 0.0.8

consume! clj

(consume! {:keys [min-batch-size consumer-group topics timeout]
           :or {min-batch-size 10 timeout 100}}
          callback)

consumer clj

(consumer & [{:keys [group]}])

poll clj

(poll consumer timeout)

record->data clj

(record->data cr)