>

누가 Neo4j apoc.periodic.repeat 함수를 사용하여 kafka에 메시지를 게시 한 적이 있습니까? 여기에 내가 가진 것이 있습니다 :

kafka 주제로 메시지를 보내려면 작동중인 쿼리가 있습니다 :

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

단, 반복 반복 기능을 사용한 경우 :

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

아무것도 일어나지 않습니다 ..

로그/디버그 로그를 확인했는데 힌트를 얻을 수 없습니다. 누구든지 나를 도울 수 있습니까?

이것은 나의 구성이다 :

# 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

  • 답변 # 1

    알겠습니다. 버그입니다 ...

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

    neo4j는 다음 릴리스에서 수정 될 것입니다.

  • 이전 java - A에서 N까지 더하는 숫자 쌍 찾기
  • 다음 cygwin 절대 경로는 c - // cygdrive/c를 제공하고 상대 경로는 정상적으로 작동합니다