带有kafka的neo4j流的失败白名单节点模式

Question

我已经配置了neo4j-stream支持，以自动将通知从neo4j发布到kafka。使用neo4j-3.4.11企业版

由于我有很多不希望用于Kafka通知的节点，因此我使用了生产者模式仅将我要发布的节点列入了白名单。考虑一下，我只想发布Car and Bike节点。

我将https://neo4j.com/docs/labs/neo4j-streams/current/producer/#producer-patterns用于配置并将PFB配置用于此用例：

kafka.zookeeper.connect=localhost:2181
kafka.bootstrap.servers=localhost:9092
kafka.num.partitions=1
kafka.retries=2
kafka.batch.size=16384
kafka.buffer.memory=33554432
kafka.reindex.batch.size=1000
kafka.session.timeout.ms=15000
kafka.connection.timeout.ms=2000
kafka.replication=1
kafka.linger.ms=1

streams.source.topic.nodes.neo4j_nodes=CAR{*};BIKE{*};
#streams.source.topic.relationships.neo4j_relationships=*
streams.source.schema.polling.interval=10000
streams.source.enable=true

但是，尽管有此模式配置，neo4j仍在发送所有其他节点数据。

是否需要进行其他设置？

Answer 1

使用Neo4j Streams插件的最新版本，用于过滤节点uses curly braces, and not parentheses的语法-我找不到以前使用括号的版本，并且尝试在最新版本上使用您的配置会导致Neo崩溃启动，因此尚不清楚您如何获得正在运行的实例。我想知道旧版本是否无效而忽略配置参数。

至少我建议将您的配置更改为：

streams.source.topic.nodes.neo4j_nodes=CAR{*};BIKE{*};

然后重试。