Neo4j apoc.periodic.repeat 不适用于 streams.publish

Question

有没有人用过Neo4j apoc.periodic.repeat 函数向kafka发布消息？这是我现在拥有的：

我有一个工作查询可以向我的 kafka 主题发送消息：

CALL streams.publish("my-neo4j-topic", "Hello World from Neo4j!")

然而，当我使用 apoc 重复功能时：

CALL apoc.periodic.repeat('kafka-only',
    'CALL streams.publish("my-neo4j-topic", "Hello World from Neo4j!")', 
5)

什么都没发生..

我检查了 log/debug 日志，但没有得到任何提示。谁能帮帮我？

这是我的配置：

# Add this for Streams Config
kafka.zookeeper.connect=localhost:2181
kafka.bootstrap.servers=localhost:9092
streams.procedures.enabled=true
streams.source.enabled=true
streams.source.schema.polling.interval=10000

Answer 1

好的，这是一个错误...

https://community.neo4j.com/t/neo4j-apoc-periodic-repeat-doesnt-work-with-streams-publish/12313/9

neo4j 将在下一个版本中修复。

Neo4j apoc.periodic.repeat 不适用于 streams.publish

Neo4j apoc.periodic.repeat doesn't work with streams.publish

neo4j

apache-kafka

neo4j-apoc