홈>
누가 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
관련 질문
- python : NEO4J APOC 외부 변수에서 JSON 로드
- NEO4J 4.4 apoc을 사용하여 db를 csv 파일로 내보내는 읽기 전용 오류를 수정하는 방법
- Neo4j는 csv의 관계 매트릭스를 수백만 개의 관계와 빠르게 통합합니다.
- javascript : Neo4j -자바스크립트와 같이 json 객체를 파괴하는 방법이 있습니까?
- 'apoc.import.json' 프로시저 호출 실패: 원인: Neo4J의 java.lang.NullPointerException
- Neo4j에서 노드 속성의 Jaccard 유사성을 기반으로 노드 간의 관계를 생성하시겠습니까?
- Neo4j용 apoc을 설치하는 방법은 무엇입니까?
- Neo4j의 병렬 쿼리에서 반복 항목 수를 수동으로 설정하는 방법은 무엇입니까?
- neo4j : 하위 그래프에 대한 CYPHER 재귀 계산
- NEO4J : 이전 쿼리에서 결과 행렬을 병렬로 평행화하는 Cypher 쿼리
알겠습니다. 버그입니다 ...
https://community.neo4j.com/t/neo4j-apoc-periodic-repeat-doesnt-work-with-streams-publish/12313/9
neo4j는 다음 릴리스에서 수정 될 것입니다.