apoc.kafka
| Qualified Name | Type |
|---|---|
apoc.kafka.consume(topic, {timeout: <long value>, from: <string>, groupId: <string>, commit: <boolean>, partitions:[{partition: <number>, offset: <number>}]}) YIELD event - Allows to consume custom topics |
Procedure |
apoc.kafka.publish(topic, payload, config) - Allows custom streaming from Neo4j to the configured stream environment |
Procedure |
apoc.kafka.publish.sync(topic, payload, config) - Allows custom synchronous streaming from Neo4j to the configured stream environment |
Procedure |