Creating Kafka stream fails in Memgraph Lab

[lucija-perkovic]

When trying to create Kafka stream in Memgraph Lab for movielens example: CREATE KAFKA STREAM movielens_stream TOPICS ratings TRANSFORM movielens.rating BOOTSTRAP_SERVERS "kafka:9092"; This error is shown: Query failed: Failed to initialize Kafka consumer movielens_stream : Local: Broker transport failure It doesn't create the stream. Using this seems to solve the issue:

CREATE KAFKA STREAM movielens_stream
TOPICS ratings
TRANSFORM movielens.rating
BOOTSTRAP_SERVERS "kafka:9092"
CREDENTIALS {'sasl.username':'public',
'sasl.password':'public',
'security.protocol':'SASL_PLAINTEXT',
'sasl.mechanism':'PLAIN'};

README should be updated for that and this webpage: https://memgraph.com/docs/memgraph/2.1.1/tutorials/graph-stream-processing-with-kafka