Versions in this module Expand all Collapse all v1 v1.5.0 Jan 30, 2026 v1.4.2 Jan 19, 2026 Changes in this version + var File_metadata_metadata_proto protoreflect.FileDescriptor + type Assignment struct + Partitions []int32 + Topic string + func (*Assignment) Descriptor() ([]byte, []int) + func (*Assignment) ProtoMessage() + func (x *Assignment) GetPartitions() []int32 + func (x *Assignment) GetTopic() string + func (x *Assignment) ProtoReflect() protoreflect.Message + func (x *Assignment) Reset() + func (x *Assignment) String() string + type BrokerRegistration struct + BrokerId string + Host string + LastHeartbeat string + Port int32 + Rack string + StartedAt string + Version string + func (*BrokerRegistration) Descriptor() ([]byte, []int) + func (*BrokerRegistration) ProtoMessage() + func (x *BrokerRegistration) GetBrokerId() string + func (x *BrokerRegistration) GetHost() string + func (x *BrokerRegistration) GetLastHeartbeat() string + func (x *BrokerRegistration) GetPort() int32 + func (x *BrokerRegistration) GetRack() string + func (x *BrokerRegistration) GetStartedAt() string + func (x *BrokerRegistration) GetVersion() string + func (x *BrokerRegistration) ProtoReflect() protoreflect.Message + func (x *BrokerRegistration) Reset() + func (x *BrokerRegistration) String() string + type CommittedOffset struct + CommittedAt string + LeaderEpoch int32 + Metadata string + Offset int64 + func (*CommittedOffset) Descriptor() ([]byte, []int) + func (*CommittedOffset) ProtoMessage() + func (x *CommittedOffset) GetCommittedAt() string + func (x *CommittedOffset) GetLeaderEpoch() int32 + func (x *CommittedOffset) GetMetadata() string + func (x *CommittedOffset) GetOffset() int64 + func (x *CommittedOffset) ProtoReflect() protoreflect.Message + func (x *CommittedOffset) Reset() + func (x *CommittedOffset) String() string + type ConsumerGroup struct + GenerationId int32 + GroupId string + Leader string + Members map[string]*GroupMember + Protocol string + ProtocolType string + RebalanceTimeoutMs int32 + State string + func (*ConsumerGroup) Descriptor() ([]byte, []int) + func (*ConsumerGroup) ProtoMessage() + func (x *ConsumerGroup) GetGenerationId() int32 + func (x *ConsumerGroup) GetGroupId() string + func (x *ConsumerGroup) GetLeader() string + func (x *ConsumerGroup) GetMembers() map[string]*GroupMember + func (x *ConsumerGroup) GetProtocol() string + func (x *ConsumerGroup) GetProtocolType() string + func (x *ConsumerGroup) GetRebalanceTimeoutMs() int32 + func (x *ConsumerGroup) GetState() string + func (x *ConsumerGroup) ProtoReflect() protoreflect.Message + func (x *ConsumerGroup) Reset() + func (x *ConsumerGroup) String() string + type GroupMember struct + Assignments []*Assignment + ClientHost string + ClientId string + HeartbeatAt string + SessionTimeoutMs int32 + Subscriptions []string + func (*GroupMember) Descriptor() ([]byte, []int) + func (*GroupMember) ProtoMessage() + func (x *GroupMember) GetAssignments() []*Assignment + func (x *GroupMember) GetClientHost() string + func (x *GroupMember) GetClientId() string + func (x *GroupMember) GetHeartbeatAt() string + func (x *GroupMember) GetSessionTimeoutMs() int32 + func (x *GroupMember) GetSubscriptions() []string + func (x *GroupMember) ProtoReflect() protoreflect.Message + func (x *GroupMember) Reset() + func (x *GroupMember) String() string + type PartitionAssignment struct + AssignedAt string + BrokerId string + Epoch int32 + func (*PartitionAssignment) Descriptor() ([]byte, []int) + func (*PartitionAssignment) ProtoMessage() + func (x *PartitionAssignment) GetAssignedAt() string + func (x *PartitionAssignment) GetBrokerId() string + func (x *PartitionAssignment) GetEpoch() int32 + func (x *PartitionAssignment) ProtoReflect() protoreflect.Message + func (x *PartitionAssignment) Reset() + func (x *PartitionAssignment) String() string + type PartitionState struct + ActiveSegment string + HighWatermark int64 + LeaderBroker string + LeaderEpoch int32 + LogEndOffset int64 + LogStartOffset int64 + Partition int32 + Segments []*SegmentInfo + Topic string + func (*PartitionState) Descriptor() ([]byte, []int) + func (*PartitionState) ProtoMessage() + func (x *PartitionState) GetActiveSegment() string + func (x *PartitionState) GetHighWatermark() int64 + func (x *PartitionState) GetLeaderBroker() string + func (x *PartitionState) GetLeaderEpoch() int32 + func (x *PartitionState) GetLogEndOffset() int64 + func (x *PartitionState) GetLogStartOffset() int64 + func (x *PartitionState) GetPartition() int32 + func (x *PartitionState) GetSegments() []*SegmentInfo + func (x *PartitionState) GetTopic() string + func (x *PartitionState) ProtoReflect() protoreflect.Message + func (x *PartitionState) Reset() + func (x *PartitionState) String() string + type SegmentInfo struct + BaseOffset int64 + CreatedAt string + SizeBytes int64 + func (*SegmentInfo) Descriptor() ([]byte, []int) + func (*SegmentInfo) ProtoMessage() + func (x *SegmentInfo) GetBaseOffset() int64 + func (x *SegmentInfo) GetCreatedAt() string + func (x *SegmentInfo) GetSizeBytes() int64 + func (x *SegmentInfo) ProtoReflect() protoreflect.Message + func (x *SegmentInfo) Reset() + func (x *SegmentInfo) String() string + type TopicConfig struct + Config map[string]string + CreatedAt string + Name string + Partitions int32 + ReplicationFactor int32 + RetentionBytes int64 + RetentionMs int64 + SegmentBytes int64 + func (*TopicConfig) Descriptor() ([]byte, []int) + func (*TopicConfig) ProtoMessage() + func (x *TopicConfig) GetConfig() map[string]string + func (x *TopicConfig) GetCreatedAt() string + func (x *TopicConfig) GetName() string + func (x *TopicConfig) GetPartitions() int32 + func (x *TopicConfig) GetReplicationFactor() int32 + func (x *TopicConfig) GetRetentionBytes() int64 + func (x *TopicConfig) GetRetentionMs() int64 + func (x *TopicConfig) GetSegmentBytes() int64 + func (x *TopicConfig) ProtoReflect() protoreflect.Message + func (x *TopicConfig) Reset() + func (x *TopicConfig) String() string
Go to main page