apoc.kafka.publish Procedure Apoc Extended Allows custom streaming from Neo4j to the configured stream environment Signature apoc.kafka.publish(topic :: STRING?, payload :: ANY?, config = {} :: MAP?) :: (value :: MAP?) Input parameters Name Type Default topic STRING? null payload ANY? null config MAP? {} Output parameters Name Type value MAP? More documentation of apoc.kafka.publish