Zerobus Connector Issue

[HarishKumarM]

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)}")

[Louis_Frolio · Accepted solution]

Hey @HarishKumarM , I did some digging and found some helpful information to help you troubleshoot.  

What the error means

Your workspace isn’t currently enrolled in the Zerobus Ingest preview. Even though Zerobus is labeled a Public Preview, it’s still gated. Workspaces have to be explicitly enrolled by Databricks before the SDK is allowed to create a stream.

That’s exactly why you’re seeing: “The workspace is not enrolled in Zerobus gated preview.”

Enrollment is handled per workspace through Databricks’ Preview Portal (an internal workflow). Until your specific workspace ID is approved and enrolled, Zerobus endpoints will consistently return UNAUTHENTICATED at stream creation time — which matches the behavior you’re hitting.

You can reach out to your account team to see if you can get enrolled in the program.

Hope this helps, Louis.