David Allen

A possibility would be to provide a "configure by query" feature. Imagine if instead of neo4j.conf, the plugin used a query that was required to return `key, value`. This could...

I believe it's probably an exception that's getting swallowed and not reported (at the cypher layer) here: https://github.com/neo4j-contrib/neo4j-streams/blob/master/consumer/src/main/kotlin/streams/procedures/StreamsSinkProcedures.kt#L39 If there's an exception it should propagage to the caller most likely,...

@pierremartignon where exactly in the docs does this need to be changed? Is it in the DLQ section? Also, I'm not quite following. kafka.bootstrap.servers is a list of URLs to...

While you were away we merged this PR that's related to error handling, to try to centralize all error & DLQ handling. https://github.com/neo4j-contrib/neo4j-streams/pull/231 A critical piece here is that error...

I believe mostly we're not looking for or raising errors. There may be some situations where if we're given bad data, it fails due to a bad assumption. In these...

Adding to this, the DBMS doesn't have strictly nested transaction support. That is, there may actually be a nested transaction at play, but I'm increasingly thinking it's not possible for...

Keeping this issue open for visibility - it's an area where action would be preferable, but so far we're not able to identify anything concrete that can be done about...

Discussion March 5: * Start with simple; add a database field to the message in the DLQ to enable "fan-out" by the user on a single DLQ * Later we...

@vishnu2497 we are actively discussing this as a team, how/when to prioritize it. It hasn't been built yet. You could really help us by describing your use case & desire...

@ivangreene we are investigating this. We think this may be a limitation in the semantics/operation of executeTransactionally, but are not yet sure. Will follow up.