I’m encountering a timeout issue when registering a stream with Memgraph. Whenever I register a stream named “test_stream”, it times out during the CHECK STREAM command. Despite the initial timeout, I can start the stream afterwards without any issues, and it runs as expected. Below are the logs I collected with the log level set to trace:
[2024-04-30 16:13:09.176][Debug][Run - memgraph] 'CREATE KAFKA STREAM test_stream TOPICS transferEdges TRANSFORM aTransferA.account_transfer_account BATCH_INTERVAL 100 BATCH_SIZE 1000 CONSUMER_GROUP mg_consumer BOOTSTRAP_SERVERS "localhost:9092"'
[2024-04-30 16:13:09.325][Debug][Run - memgraph] 'CHECK STREAM test_stream BATCH_LIMIT 1 TIMEOUT 30000'
[2024-04-30 16:13:09.517][Trace] Error message: Kafka consumer test_stream check failed: timeout reached
[2024-04-30 16:13:09.923][Trace] Reset received
Every stream registration follows this pattern of timing out initially but functioning correctly thereafter. Is there a way to bypass the CHECK STREAM command?
New contributor
Schmetter is a new contributor to this site. Take care in asking for clarification, commenting, and answering.
Check out our Code of Conduct.