apoc.kafka
| 限定名称 | 类型 |
|---|---|
apoc.kafka.consume(topic, {timeout: <长整型值>, from: <字符串>, groupId: <字符串>, commit: <布尔值>, partitions:[{partition: <数字>, offset: <数字>}]}) YIELD event - 允许消费自定义主题 |
过程 |
apoc.kafka.publish(topic, payload, config) - 允许从 Neo4j 到已配置流环境的自定义流式传输 |
过程 |
apoc.kafka.publish.sync(topic, payload, config) - 允许从 Neo4j 到已配置流环境的自定义同步流式传输 |
过程 |