apoc.kafka.consume Procedure Apoc Extended Allows to consume custom topics Signature apoc.kafka.consume(topic :: STRING?, config = {} :: MAP?) :: (value :: MAP?) Input parameters Name Type Default topic STRING? null config MAP? {} Output parameters Name Type value MAP? More documentation of apoc.kafka.consume