When someone wants to write inside a default stream, he has to manually append the suffix /_default like in spark project or beam

This is an implementation detail that should not be visible to the client and the API should provide a way to get the default stream name