I was trying to implement the example posted on the below link for Zerobus connector to test its functionality on my free edition workspace but unfortunately I am getting below error.
Reference Code: https://learn.microsoft.com/en-us/azure/databricks/ingestion/zerobus-ingest
ERROR:zerobus_sdk:Non-retriable gRPC error during stream creation: <_MultiThreadedRendezvous of RPC that terminated with: status = StatusCode.UNAUTHENTICATED details = "{"X-Databricks-Reason-Phrase":"The workspace is not enrolled in Zerobus gated preview."}" debug_error_string = "UNKNOWN:Error received from peer {grpc_message:"{\"X-Databricks-Reason-Phrase\":\"The workspace is not enrolled in Zerobus gated preview.\"}", grpc_status:16, created_time:"2026-01-12T05:53:00.344531824+00:00"}" >
NonRetriableException: Failed to create a stream: <_MultiThreadedRendezvous of RPC that terminated with: status = StatusCode.UNAUTHENTICATED details = "{"X-Databricks-Reason-Phrase":"The workspace is not enrolled in Zerobus gated preview."}" debug_error_string = "UNKNOWN:Error received from peer {grpc_message:"{\"X-Databricks-Reason-Phrase\":\"The workspace is not enrolled in Zerobus gated preview.\"}", grpc_status:16, created_time:"2026-01-12T05:53:00.344531824+00:00"}" > [Trace ID: 00-cee668017de7f9828752880d8db851f6-eb07a5831899d118-00]
File /local_disk0/.ephemeral_nfs/envs/pythonEnv-d6b2707d-4ceb-4202-b9ff-a67b95c58c42/lib/python3.12/site-packages/zerobus/sdk/sync/zerobus_sdk.py:261, in ZerobusStream.__create_stream(self) 260 if self.__stream_created_exception: --> 261 raise self.__stream_created_exception 262 if not success_stream:
File /local_disk0/.ephemeral_nfs/envs/pythonEnv-d6b2707d-4ceb-4202-b9ff-a67b95c58c42/lib/python3.12/site-packages/zerobus/sdk/sync/zerobus_sdk.py:275, in ZerobusStream.__create_stream(self) 272 if e.code() in NOT_RETRIABLE_GRPC_CODES: 273 # Non-retriable gRPC errors 274 logger.error(f"Non-retriable gRPC error during stream creation: {str(e)}") --> 275 raise NonRetriableException(f"Failed to create a stream: {str(e)}") from e 276 else: 277 # Retriable gRPC errors 278 logger.error(f"Retriable gRPC error during stream creation: {str(e)}")
