apoc.kafka.publish.sync Procedure Apoc Extended Allows custom synchronous streaming from Neo4j to the configured stream environment Signature apoc.kafka.publish.sync(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.sync