Neo4j-Streams Release 3.4.1 and Kafka Connect Plugin Release 1.0.0
We're excited about the new release. Big thanks to @conker84 from our partner Larus IT for all the hard work of building this integration.
Thanks to your feedback the Neo4j extension saw a number of fixed issues and more testing in the field, please continue to try it for different use-cases and let us know how well it works for you. Special thanks to @lju-lazarevic and @sarmbruster
Kafka Connect Plugin Release 1.0.0
Finally the Neo4j Kafka integration is available as Connect Plugin. We provide the sink functionality which will also be available on Confluent Hub.
We provide the ability to test the plugin locally with the docker compose setup we provided.
For more details see the docs
New Procedure
We added a new procedure to receive events from a topic and use them in your Cypher statement. That's useful both for testing and also for consuming events directly as part of another workflow.
We describe how to use it in the procedure documentation.
Batching
To allow better control of batching, we added a configuration parameter, batch.size that together with the Kafka setting max.poll.records allows to consume events in bulk(batch)