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.
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.