Search code examples
memgraphdb

When creating a Kafka stream with GQLAlchemy which arguments are required?


I've taken a look at the documentation on creating Kafka streams using GQLAlchemy, but I don't get which parameters are optional and which ones are required.


Solution

  • Required parameters are name, topics and transform. When you create MemgraphKafkaStream instance, you actually run CREATE KAFKA STREAM query, so it's best to refer to the Memgraph docs for such questions. There you can see that other arguments are optional.