Only one consumer can subscribe to the topic at a time.

Only one consumer (the active consumer) receives messages at any given time.

Multiple consumers can subscribe to the topic concurrently.

The topic name is not valid.

Any error that requires client retry operation with a fresh lookup.

Subscription not found.

Topic not found.

exclusive access for producer.

multiple producers can publish on a topic.

Enum value maps for ConsumerRequest_SubscriptionType.

Enum value maps for ConsumerRequest_SubscriptionType.

ConsumerService_ServiceDesc is the grpc.ServiceDesc for ConsumerService service.

Discovery_ServiceDesc is the grpc.ServiceDesc for Discovery service.

Enum value maps for DispatchStrategy.

Enum value maps for DispatchStrategy.

Enum value maps for ErrorType.

Enum value maps for ErrorType.

HealthCheck_ServiceDesc is the grpc.ServiceDesc for HealthCheck service.

Enum value maps for HealthCheckRequest_ClientType.

Enum value maps for HealthCheckRequest_ClientType.

Enum value maps for HealthCheckResponse_ClientStatus.

Enum value maps for HealthCheckResponse_ClientStatus.

Enum value maps for ProducerAccessMode.

Enum value maps for ProducerAccessMode.

ProducerService_ServiceDesc is the grpc.ServiceDesc for ProducerService service.

Enum value maps for RetentionPolicy.

Enum value maps for RetentionPolicy.

Enum value maps for Schema_TypeSchema.

Enum value maps for Schema_TypeSchema.

Enum value maps for TopicLookupResponse_LookupType.

Enum value maps for TopicLookupResponse_LookupType.

Create Consumer request.

Create Consumer response.

A message that encapsulate the error details.

Producer receive acknowledge for the sent message.

Unique ID of the message.

Create Producer request.

Create Producer response.

The message that is sent by producer to topic and then to consumer.

Message representing topic retention strategy.

UnimplementedConsumerServiceServer must be embedded to have forward compatible implementations.

UnimplementedDiscoveryServer must be embedded to have forward compatible implementations.

UnimplementedHealthCheckServer must be embedded to have forward compatible implementations.

UnimplementedProducerServiceServer must be embedded to have forward compatible implementations.

ConsumerServiceClient is the client API for ConsumerService service.

ConsumerServiceServer is the server API for ConsumerService service.

DiscoveryClient is the client API for Discovery service.

DiscoveryServer is the server API for Discovery service.

HealthCheckClient is the client API for HealthCheck service.

HealthCheckServer is the server API for HealthCheck service.

ProducerServiceClient is the client API for ProducerService service.

ProducerServiceServer is the server API for ProducerService service.

UnsafeConsumerServiceServer may be embedded to opt out of forward compatibility for this service.

UnsafeDiscoveryServer may be embedded to opt out of forward compatibility for this service.

UnsafeHealthCheckServer may be embedded to opt out of forward compatibility for this service.

UnsafeProducerServiceServer may be embedded to opt out of forward compatibility for this service.