Kafka.Consumer

data Consumer :: Type

type ConsumerConfig = { autoCommit :: Boolean, groupId :: String, readUncommitted :: Boolean }

type SubscriptionConfig = { topic :: String }

makeConsumer :: Kafka -> ConsumerConfig -> Consumer

connect :: Consumer -> Aff Unit

subscribe :: Consumer -> SubscriptionConfig -> Aff Unit

type ConsumerMessage = { key :: Maybe Buffer, offset :: Offset, value :: Buffer }

type ConsumerBatch = { fetchedOffset :: Offset, highWatermark :: Offset, messages :: Array ConsumerMessage, partition :: Partition, topic :: Topic }

type Heartbeat = Aff Unit

type ResolveOffset = Offset -> Effect Unit

type CommitOffsetsIfNecessary = Aff Unit

type OffsetInfo = { topics :: Array { partitions :: Array { offset :: Offset, partition :: Partition }, topic :: Topic } }

toOffsetInfo :: InternalOffsetInfo -> Effect OffsetInfo

type UncommittedOffsets = Effect OffsetInfo

type IsStale = Effect Boolean

type IsRunning = Effect Boolean

type EachBatch = ConsumerBatch -> ResolveOffset -> Heartbeat -> CommitOffsetsIfNecessary -> UncommittedOffsets -> IsRunning -> IsStale -> (Aff Unit)

eachBatch :: Consumer -> Boolean -> EachBatch -> Aff Unit

disconnect :: Consumer -> Aff Unit