Following the instructions to integrate Kafka in Memgraph, I realised, that the Source Connector doesn't implement a window functionality. The
"neo4j.streaming.property": "timestamp", "neo4j.streaming.from": "LAST_COMMITTED"
properties are set, but there is no restriction in the query assuring this behavior. For example, at Neo4j, the Source Instance can be configured with a $lastCheck restriction in the source query, to guarantee that only newly inserted vertices are considered. When running the Memgraph Source, the same SensorData nodes are printed into my-topic over and over again. I tried implementing a $lastCheck-restriction, but the source immediately fails. Am I missing something?