proto

type APIClient interface {
	// CreateStream creates a new stream attached to a NATS subject. It returns
	// an AlreadyExists status code if a stream with the given subject and name
	// already exists.
	CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*CreateStreamResponse, error)
	// DeleteStream deletes a stream.
	DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*DeleteStreamResponse, error)
	// PauseStream pauses a stream's partitions. If no partitions are
	// specified, all of the stream's partitions will be paused. Partitions are
	// resumed when they are published to via the Liftbridge Publish API.
	PauseStream(ctx context.Context, in *PauseStreamRequest, opts ...grpc.CallOption) (*PauseStreamResponse, error)
	// SetStreamReadonly sets a read-only flag to a partition. Returns a
	// NoSuchStream error code if the given stream or partition does not exist.
	SetStreamReadonly(ctx context.Context, in *SetStreamReadonlyRequest, opts ...grpc.CallOption) (*SetStreamReadonlyResponse, error)
	// Subscribe creates an ephemeral subscription for the given stream. It
	// begins to receive messages starting at the given offset and waits for
	// new messages when it reaches the end of the stream. Use the request
	// context to close the subscription.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (API_SubscribeClient, error)
	// FetchMetadata retrieves the latest cluster metadata, including stream
	// broker information.
	FetchMetadata(ctx context.Context, in *FetchMetadataRequest, opts ...grpc.CallOption) (*FetchMetadataResponse, error)
	// FetchPartitionMetadata retrieves the latest partition metadata from partition leader
	// The main interest is to retrieve Highest Watermark and Newest Offset
	FetchPartitionMetadata(ctx context.Context, in *FetchPartitionMetadataRequest, opts ...grpc.CallOption) (*FetchPartitionMetadataResponse, error)
	// Publish a new message to a stream. If the AckPolicy is not NONE and a
	// deadline is provided, this will synchronously block until the ack is
	// received. If the ack is not received in time, a DeadlineExceeded status
	// code is returned.
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	// PublishAsync is used to asynchronously publish messages to a stream in a
	// pipelined fashion. This returns a stream which will yield
	// PublishResponses for messages whose AckPolicy is not NONE.
	PublishAsync(ctx context.Context, opts ...grpc.CallOption) (API_PublishAsyncClient, error)
	// Publish a Liftbridge message to a NATS subject. If the AckPolicy is not NONE and a
	// deadline is provided, this will synchronously block until the first ack
	// is received. If an ack is not received in time, a DeadlineExceeded
	// status code is returned.
	PublishToSubject(ctx context.Context, in *PublishToSubjectRequest, opts ...grpc.CallOption) (*PublishToSubjectResponse, error)
	// SetCursor stores a cursor position for a particular stream partition
	// which is uniquely identified by an opaque string.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	SetCursor(ctx context.Context, in *SetCursorRequest, opts ...grpc.CallOption) (*SetCursorResponse, error)
	// FetchCursor retrieves a partition cursor position.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	FetchCursor(ctx context.Context, in *FetchCursorRequest, opts ...grpc.CallOption) (*FetchCursorResponse, error)
	// JoinConsumerGroup adds a consumer to a consumer group. If the group does
	// not exist, it will create it first.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	JoinConsumerGroup(ctx context.Context, in *JoinConsumerGroupRequest, opts ...grpc.CallOption) (*JoinConsumerGroupResponse, error)
	// LeaveConsumerGroup removes a consumer from a consumer group.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	LeaveConsumerGroup(ctx context.Context, in *LeaveConsumerGroupRequest, opts ...grpc.CallOption) (*LeaveConsumerGroupResponse, error)
	// FetchConsumerGroupAssignments retrieves the partition assignments for a
	// consumer. This also acts as a heartbeat for the consumer so that the
	// coordinator keeps the consumer active in the group.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	FetchConsumerGroupAssignments(ctx context.Context, in *FetchConsumerGroupAssignmentsRequest, opts ...grpc.CallOption) (*FetchConsumerGroupAssignmentsResponse, error)
	// ReportConsumerGroupCoordinator reports a consumer group coordinator as
	// failed. If a majority of the group's members report the coordinator
	// within a bounded period, the cluster will select a new coordinator.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	ReportConsumerGroupCoordinator(ctx context.Context, in *ReportConsumerGroupCoordinatorRequest, opts ...grpc.CallOption) (*ReportConsumerGroupCoordinatorResponse, error)
}

type APIServer interface {
	// CreateStream creates a new stream attached to a NATS subject. It returns
	// an AlreadyExists status code if a stream with the given subject and name
	// already exists.
	CreateStream(context.Context, *CreateStreamRequest) (*CreateStreamResponse, error)
	// DeleteStream deletes a stream.
	DeleteStream(context.Context, *DeleteStreamRequest) (*DeleteStreamResponse, error)
	// PauseStream pauses a stream's partitions. If no partitions are
	// specified, all of the stream's partitions will be paused. Partitions are
	// resumed when they are published to via the Liftbridge Publish API.
	PauseStream(context.Context, *PauseStreamRequest) (*PauseStreamResponse, error)
	// SetStreamReadonly sets a read-only flag to a partition. Returns a
	// NoSuchStream error code if the given stream or partition does not exist.
	SetStreamReadonly(context.Context, *SetStreamReadonlyRequest) (*SetStreamReadonlyResponse, error)
	// Subscribe creates an ephemeral subscription for the given stream. It
	// begins to receive messages starting at the given offset and waits for
	// new messages when it reaches the end of the stream. Use the request
	// context to close the subscription.
	Subscribe(*SubscribeRequest, API_SubscribeServer) error
	// FetchMetadata retrieves the latest cluster metadata, including stream
	// broker information.
	FetchMetadata(context.Context, *FetchMetadataRequest) (*FetchMetadataResponse, error)
	// FetchPartitionMetadata retrieves the latest partition metadata from partition leader
	// The main interest is to retrieve Highest Watermark and Newest Offset
	FetchPartitionMetadata(context.Context, *FetchPartitionMetadataRequest) (*FetchPartitionMetadataResponse, error)
	// Publish a new message to a stream. If the AckPolicy is not NONE and a
	// deadline is provided, this will synchronously block until the ack is
	// received. If the ack is not received in time, a DeadlineExceeded status
	// code is returned.
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	// PublishAsync is used to asynchronously publish messages to a stream in a
	// pipelined fashion. This returns a stream which will yield
	// PublishResponses for messages whose AckPolicy is not NONE.
	PublishAsync(API_PublishAsyncServer) error
	// Publish a Liftbridge message to a NATS subject. If the AckPolicy is not NONE and a
	// deadline is provided, this will synchronously block until the first ack
	// is received. If an ack is not received in time, a DeadlineExceeded
	// status code is returned.
	PublishToSubject(context.Context, *PublishToSubjectRequest) (*PublishToSubjectResponse, error)
	// SetCursor stores a cursor position for a particular stream partition
	// which is uniquely identified by an opaque string.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	SetCursor(context.Context, *SetCursorRequest) (*SetCursorResponse, error)
	// FetchCursor retrieves a partition cursor position.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	FetchCursor(context.Context, *FetchCursorRequest) (*FetchCursorResponse, error)
	// JoinConsumerGroup adds a consumer to a consumer group. If the group does
	// not exist, it will create it first.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	JoinConsumerGroup(context.Context, *JoinConsumerGroupRequest) (*JoinConsumerGroupResponse, error)
	// LeaveConsumerGroup removes a consumer from a consumer group.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	LeaveConsumerGroup(context.Context, *LeaveConsumerGroupRequest) (*LeaveConsumerGroupResponse, error)
	// FetchConsumerGroupAssignments retrieves the partition assignments for a
	// consumer. This also acts as a heartbeat for the consumer so that the
	// coordinator keeps the consumer active in the group.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	FetchConsumerGroupAssignments(context.Context, *FetchConsumerGroupAssignmentsRequest) (*FetchConsumerGroupAssignmentsResponse, error)
	// ReportConsumerGroupCoordinator reports a consumer group coordinator as
	// failed. If a majority of the group's members report the coordinator
	// within a bounded period, the cluster will select a new coordinator.
	//
	// NOTE: This is a beta endpoint and is subject to change. It is not
	// included as part of Liftbridge's semantic versioning scheme.
	ReportConsumerGroupCoordinator(context.Context, *ReportConsumerGroupCoordinatorRequest) (*ReportConsumerGroupCoordinatorResponse, error)
}

type API_PublishAsyncClient interface {
	Send(*PublishRequest) error
	Recv() (*PublishResponse, error)
	grpc.ClientStream
}

type API_PublishAsyncServer interface {
	Send(*PublishResponse) error
	Recv() (*PublishRequest, error)
	grpc.ServerStream
}

type API_SubscribeClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type API_SubscribeServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type Ack struct {
	Stream               string    `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	PartitionSubject     string    `protobuf:"bytes,2,opt,name=partitionSubject,proto3" json:"partitionSubject,omitempty"`
	MsgSubject           string    `protobuf:"bytes,3,opt,name=msgSubject,proto3" json:"msgSubject,omitempty"`
	Offset               int64     `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	AckInbox             string    `protobuf:"bytes,5,opt,name=ackInbox,proto3" json:"ackInbox,omitempty"`
	CorrelationId        string    `protobuf:"bytes,6,opt,name=correlationId,proto3" json:"correlationId,omitempty"`
	AckPolicy            AckPolicy `protobuf:"varint,7,opt,name=ackPolicy,proto3,enum=proto.AckPolicy" json:"ackPolicy,omitempty"`
	ReceptionTimestamp   int64     `protobuf:"varint,8,opt,name=receptionTimestamp,proto3" json:"receptionTimestamp,omitempty"`
	CommitTimestamp      int64     `protobuf:"varint,9,opt,name=commitTimestamp,proto3" json:"commitTimestamp,omitempty"`
	AckError             Ack_Error `protobuf:"varint,10,opt,name=ackError,proto3,enum=proto.Ack_Error" json:"ackError,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

type AckPolicy int32

type Ack_Error int32

type ActivityStreamEvent struct {
	Id                   uint64                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Op                   ActivityStreamOp      `protobuf:"varint,2,opt,name=op,proto3,enum=proto.ActivityStreamOp" json:"op,omitempty"`
	CreateStreamOp       *CreateStreamOp       `protobuf:"bytes,3,opt,name=createStreamOp,proto3" json:"createStreamOp,omitempty"`
	DeleteStreamOp       *DeleteStreamOp       `protobuf:"bytes,4,opt,name=deleteStreamOp,proto3" json:"deleteStreamOp,omitempty"`
	PauseStreamOp        *PauseStreamOp        `protobuf:"bytes,5,opt,name=pauseStreamOp,proto3" json:"pauseStreamOp,omitempty"`
	ResumeStreamOp       *ResumeStreamOp       `protobuf:"bytes,6,opt,name=resumeStreamOp,proto3" json:"resumeStreamOp,omitempty"`
	SetStreamReadonlyOp  *SetStreamReadonlyOp  `protobuf:"bytes,7,opt,name=setStreamReadonlyOp,proto3" json:"setStreamReadonlyOp,omitempty"`
	JoinConsumerGroupOp  *JoinConsumerGroupOp  `protobuf:"bytes,8,opt,name=joinConsumerGroupOp,proto3" json:"joinConsumerGroupOp,omitempty"`
	LeaveConsumerGroupOp *LeaveConsumerGroupOp `protobuf:"bytes,9,opt,name=leaveConsumerGroupOp,proto3" json:"leaveConsumerGroupOp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

type ActivityStreamOp int32

type Broker struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Host                 string   `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port                 int32    `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	PartitionCount       int32    `protobuf:"varint,4,opt,name=partitionCount,proto3" json:"partitionCount,omitempty"`
	LeaderCount          int32    `protobuf:"varint,5,opt,name=leaderCount,proto3" json:"leaderCount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Consumer struct {
	GroupId              string   `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupEpoch           uint64   `protobuf:"varint,2,opt,name=groupEpoch,proto3" json:"groupEpoch,omitempty"`
	ConsumerId           string   `protobuf:"bytes,3,opt,name=consumerId,proto3" json:"consumerId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ConsumerGroupMetadata struct {
	GroupId              string                      `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"`
	Error                ConsumerGroupMetadata_Error `protobuf:"varint,2,opt,name=error,proto3,enum=proto.ConsumerGroupMetadata_Error" json:"error,omitempty"`
	Coordinator          string                      `protobuf:"bytes,3,opt,name=coordinator,proto3" json:"coordinator,omitempty"`
	Epoch                uint64                      `protobuf:"varint,4,opt,name=epoch,proto3" json:"epoch,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

type ConsumerGroupMetadata_Error int32

type CreateStreamOp struct {
	Stream               string   `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Partitions           []int32  `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type CreateStreamRequest struct {
	Subject                       string         `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Name                          string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Group                         string         `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	ReplicationFactor             int32          `protobuf:"varint,4,opt,name=replicationFactor,proto3" json:"replicationFactor,omitempty"`
	Partitions                    int32          `protobuf:"varint,5,opt,name=partitions,proto3" json:"partitions,omitempty"`
	RetentionMaxBytes             *NullableInt64 `protobuf:"bytes,6,opt,name=retentionMaxBytes,proto3" json:"retentionMaxBytes,omitempty"`
	RetentionMaxMessages          *NullableInt64 `protobuf:"bytes,7,opt,name=retentionMaxMessages,proto3" json:"retentionMaxMessages,omitempty"`
	RetentionMaxAge               *NullableInt64 `protobuf:"bytes,8,opt,name=retentionMaxAge,proto3" json:"retentionMaxAge,omitempty"`
	CleanerInterval               *NullableInt64 `protobuf:"bytes,9,opt,name=cleanerInterval,proto3" json:"cleanerInterval,omitempty"`
	SegmentMaxBytes               *NullableInt64 `protobuf:"bytes,10,opt,name=segmentMaxBytes,proto3" json:"segmentMaxBytes,omitempty"`
	SegmentMaxAge                 *NullableInt64 `protobuf:"bytes,11,opt,name=segmentMaxAge,proto3" json:"segmentMaxAge,omitempty"`
	CompactMaxGoroutines          *NullableInt32 `protobuf:"bytes,12,opt,name=compactMaxGoroutines,proto3" json:"compactMaxGoroutines,omitempty"`
	CompactEnabled                *NullableBool  `protobuf:"bytes,13,opt,name=compactEnabled,proto3" json:"compactEnabled,omitempty"`
	AutoPauseTime                 *NullableInt64 `protobuf:"bytes,14,opt,name=autoPauseTime,proto3" json:"autoPauseTime,omitempty"`
	AutoPauseDisableIfSubscribers *NullableBool  `protobuf:"bytes,15,opt,name=autoPauseDisableIfSubscribers,proto3" json:"autoPauseDisableIfSubscribers,omitempty"`
	MinIsr                        *NullableInt32 `protobuf:"bytes,16,opt,name=minIsr,proto3" json:"minIsr,omitempty"`
	OptimisticConcurrencyControl  *NullableBool  `protobuf:"bytes,17,opt,name=optimisticConcurrencyControl,proto3" json:"optimisticConcurrencyControl,omitempty"`
	Encryption                    *NullableBool  `protobuf:"bytes,18,opt,name=encryption,proto3" json:"encryption,omitempty"`
	XXX_NoUnkeyedLiteral          struct{}       `json:"-"`
	XXX_unrecognized              []byte         `json:"-"`
	XXX_sizecache                 int32          `json:"-"`
}

type CreateStreamResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type DeleteStreamOp struct {
	Stream               string   `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type DeleteStreamRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type DeleteStreamResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type FetchConsumerGroupAssignmentsRequest struct {
	GroupId              string   `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"`
	ConsumerId           string   `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"`
	Epoch                uint64   `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type FetchConsumerGroupAssignmentsResponse struct {
	Epoch                uint64                 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Assignments          []*PartitionAssignment `protobuf:"bytes,2,rep,name=assignments,proto3" json:"assignments,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

type FetchCursorRequest struct {
	Stream               string   `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Partition            int32    `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	CursorId             string   `protobuf:"bytes,3,opt,name=cursorId,proto3" json:"cursorId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type FetchCursorResponse struct {
	Offset               int64    `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type FetchMetadataRequest struct {
	Streams              []string `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	Groups               []string `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type FetchMetadataResponse struct {
	Brokers              []*Broker                `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"`
	StreamMetadata       []*StreamMetadata        `protobuf:"bytes,2,rep,name=streamMetadata,proto3" json:"streamMetadata,omitempty"`
	GroupMetadata        []*ConsumerGroupMetadata `protobuf:"bytes,3,rep,name=groupMetadata,proto3" json:"groupMetadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

type FetchPartitionMetadataRequest struct {
	Stream               string   `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Partition            int32    `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type FetchPartitionMetadataResponse struct {
	Metadata             *PartitionMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

type JoinConsumerGroupOp struct {
	GroupId              string   `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"`
	ConsumerId           string   `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"`
	Streams              []string `protobuf:"bytes,3,rep,name=streams,proto3" json:"streams,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type JoinConsumerGroupRequest struct {
	GroupId              string   `protobuf:"bytes,1,opt,name=groupId,proto3" json:"groupId,omitempty"`
	ConsumerId           string   `protobuf:"bytes,2,opt,name=consumerId,proto3" json:"consumerId,omitempty"`
	Streams              []string `protobuf:"bytes,3,rep,name=streams,proto3" json:"streams,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type JoinConsumerGroupResponse struct {
	Coordinator          string   `protobuf:"bytes,1,opt,name=coordinator,proto3" json:"coordinator,omitempty"`
	Epoch                uint64   `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	ConsumerTimeout      int64    `protobuf:"varint,3,opt,name=consumerTimeout,proto3" json:"consumerTimeout,omitempty"`
	CoordinatorTimeout   int64    `protobuf:"varint,4,opt,name=coordinatorTimeout,proto3" json:"coordinatorTimeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}