无法使用 kafka 将 neo4j-stream 的节点模式列入白名单

Question

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

不想被考虑用于 Kafka 通知的节点，因此我使用生产者模式将我想要发布的节点列入白名单。假设我只想发布"汽车和自行车"节点。

我参考 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 插件，过滤节点的语法使用大括号，而不是括号 - 我找不到以前使用过括号的版本，并且尝试在最新版本上使用您的配置只会在 Neo 启动时崩溃，因此不清楚您如何获得正在运行的实例。我想知道如果配置参数无效，旧版本是否默默忽略了配置参数。

无论如何，至少我建议您将您的配置更改为：

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

，然后重试。