Сбой для шаблона узла белого списка для потока neo4j с kafka - PullRequest
Новая
       17

Сбой для шаблона узла белого списка для потока neo4j с kafka

0 голосов
/ 21 сентября 2019

Я настроил поддержку neo4j-stream для автоматической публикации уведомлений для kafka из neo4j.Использование neo4j-3.4.11 Enterprise Edition

Поскольку у меня большое количество узлов, которые я не хочу рассматривать для уведомления 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 по-прежнему отправляет данные всех других узлов, несмотря на эту конфигурацию шаблона.

Есть ли какие-либо дополнительные настройки, которые необходимо выполнить?

1 Ответ

0 голосов
/ 25 сентября 2019

В самых последних версиях плагина Neo4j Streams синтаксис для фильтрации узлов использует фигурные скобки, а не круглые скобки - я не могу найти версию, которая раньше использовала круглые скобки, и пытаюсь использовать вашуКонфигурация в последней версии просто сбивает Neo при запуске, поэтому неясно, как вы получаете работающий экземпляр.Мне интересно, если старые версии молча игнорировали параметр конфигурации, если он был недействительным.

Независимо от того, по крайней мере, я бы предложил изменить вашу конфигурацию на: 

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

и повторить попытку.

...