#********************************************************************
# Neo4j Streams Plugin properties
#********************************************************************
<% unless node['neo4j']['config']['kafka.zookeeper.connect'].empty? %>
kafka.zookeeper.connect=<%= node['neo4j']['config']['kafka.zookeeper.connect'] %>
<% end -%>
<% unless node['neo4j']['config']['kafka.bootstrap.servers'].empty? %>
kafka.bootstrap.servers=<%= node['neo4j']['config']['kafka.bootstrap.servers'] %>
<% end -%>
<% unless node['neo4j']['config']['kafka.security.protocol'].empty? %>
kafka.security.protocol=<%= node['neo4j']['config']['kafka.security.protocol'] %>
<% end -%>
<% unless node['neo4j']['config']['kafka.ssl.truststore.location'].empty? %>
kafka.ssl.truststore.location=<%= node['neo4j']['config']['kafka.ssl.truststore.location'] %>
<% end -%>
<% unless node['neo4j']['config']['kafka.streams.log.compaction.strategy'].empty? %>
kafka.streams.log.compaction.strategy=<%= node['neo4j']['config']['kafka.streams.log.compaction.strategy'] %>
<% end -%>

streams.procedures.enabled=<%= node['neo4j']['config']['streams.procedures.enabled'] %>
streams.sink.enabled=<%= node['neo4j']['config']['streams.sink.enabled'] %>
streams.source.enabled=<%= node['neo4j']['config']['streams.source.enabled'] %>
<% if node['neo4j']['streams']['environment'] == 'dev' %>
streams.source.txhandler.enabled=<%= node['neo4j']['config']['streams.source.txhandler.enabled'] %>
<% end -%>

<% if node['neo4j']['config']['streams.source.enabled'] == 'true' %>
streams.source.schema.polling.interval=<%= node['neo4j']['config']['streams.source.schema.polling.interval'] %>
<% unless node['neo4j']['config']['streams.source.topic_node_pattern_mappings'].empty? %>
<% Hash(node['neo4j']['config']['streams.source.topic_node_pattern_mappings']).each do |topic, pattern| %>
streams.source.topic.nodes.<%= topic %>=<%= pattern %>
<% end %>
<% end -%>
<% unless node['neo4j']['config']['streams.source.topic_relationship_pattern_mappings'].empty? %>
<% Hash(node['neo4j']['config']['streams.source.topic_relationship_pattern_mappings']).each do |topic, pattern| %>
streams.source.topic.relationships.<%= topic %>=<%= pattern %>
streams.source.topic.relationships.<%= topic %>.key_strategy=all
<% end %>
<% end -%>
<% end -%>