metadata

type Assignment struct {
	Topic      string  `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partitions []int32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

type BrokerRegistration struct {
	BrokerId      string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_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"`
	Rack          string `protobuf:"bytes,4,opt,name=rack,proto3" json:"rack,omitempty"`
	StartedAt     string `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	LastHeartbeat string `protobuf:"bytes,6,opt,name=last_heartbeat,json=lastHeartbeat,proto3" json:"last_heartbeat,omitempty"`
	Version       string `protobuf:"bytes,7,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type CommittedOffset struct {
	Offset      int64  `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Metadata    string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	CommittedAt string `protobuf:"bytes,3,opt,name=committed_at,json=committedAt,proto3" json:"committed_at,omitempty"`
	LeaderEpoch int32  `protobuf:"varint,4,opt,name=leader_epoch,json=leaderEpoch,proto3" json:"leader_epoch,omitempty"`
	// contains filtered or unexported fields
}

type ConsumerGroup struct {
	GroupId            string                  `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	State              string                  `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	ProtocolType       string                  `protobuf:"bytes,3,opt,name=protocol_type,json=protocolType,proto3" json:"protocol_type,omitempty"`
	Protocol           string                  `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Leader             string                  `protobuf:"bytes,5,opt,name=leader,proto3" json:"leader,omitempty"`
	GenerationId       int32                   `protobuf:"varint,6,opt,name=generation_id,json=generationId,proto3" json:"generation_id,omitempty"`
	Members            map[string]*GroupMember `` /* 141-byte string literal not displayed */
	RebalanceTimeoutMs int32                   `protobuf:"varint,8,opt,name=rebalance_timeout_ms,json=rebalanceTimeoutMs,proto3" json:"rebalance_timeout_ms,omitempty"`
	// contains filtered or unexported fields
}

type GroupMember struct {
	ClientId         string        `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	ClientHost       string        `protobuf:"bytes,2,opt,name=client_host,json=clientHost,proto3" json:"client_host,omitempty"`
	HeartbeatAt      string        `protobuf:"bytes,3,opt,name=heartbeat_at,json=heartbeatAt,proto3" json:"heartbeat_at,omitempty"`
	Assignments      []*Assignment `protobuf:"bytes,4,rep,name=assignments,proto3" json:"assignments,omitempty"`
	Subscriptions    []string      `protobuf:"bytes,5,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	SessionTimeoutMs int32         `protobuf:"varint,6,opt,name=session_timeout_ms,json=sessionTimeoutMs,proto3" json:"session_timeout_ms,omitempty"`
	// contains filtered or unexported fields
}

type PartitionAssignment struct {
	BrokerId   string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	Epoch      int32  `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	AssignedAt string `protobuf:"bytes,3,opt,name=assigned_at,json=assignedAt,proto3" json:"assigned_at,omitempty"`
	// contains filtered or unexported fields
}

type PartitionState struct {
	Topic          string         `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition      int32          `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	LeaderBroker   string         `protobuf:"bytes,3,opt,name=leader_broker,json=leaderBroker,proto3" json:"leader_broker,omitempty"`
	LeaderEpoch    int32          `protobuf:"varint,4,opt,name=leader_epoch,json=leaderEpoch,proto3" json:"leader_epoch,omitempty"`
	LogStartOffset int64          `protobuf:"varint,5,opt,name=log_start_offset,json=logStartOffset,proto3" json:"log_start_offset,omitempty"`
	LogEndOffset   int64          `protobuf:"varint,6,opt,name=log_end_offset,json=logEndOffset,proto3" json:"log_end_offset,omitempty"`
	HighWatermark  int64          `protobuf:"varint,7,opt,name=high_watermark,json=highWatermark,proto3" json:"high_watermark,omitempty"`
	ActiveSegment  string         `protobuf:"bytes,8,opt,name=active_segment,json=activeSegment,proto3" json:"active_segment,omitempty"`
	Segments       []*SegmentInfo `protobuf:"bytes,9,rep,name=segments,proto3" json:"segments,omitempty"`
	// contains filtered or unexported fields
}

type SegmentInfo struct {
	BaseOffset int64  `protobuf:"varint,1,opt,name=base_offset,json=baseOffset,proto3" json:"base_offset,omitempty"`
	SizeBytes  int64  `protobuf:"varint,2,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	CreatedAt  string `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

type TopicConfig struct {
	Name              string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Partitions        int32             `protobuf:"varint,2,opt,name=partitions,proto3" json:"partitions,omitempty"`
	ReplicationFactor int32             `protobuf:"varint,3,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	RetentionMs       int64             `protobuf:"varint,4,opt,name=retention_ms,json=retentionMs,proto3" json:"retention_ms,omitempty"`
	RetentionBytes    int64             `protobuf:"varint,5,opt,name=retention_bytes,json=retentionBytes,proto3" json:"retention_bytes,omitempty"`
	SegmentBytes      int64             `protobuf:"varint,6,opt,name=segment_bytes,json=segmentBytes,proto3" json:"segment_bytes,omitempty"`
	CreatedAt         string            `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Config            map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}