get

Documentation

Index

• func Command(base BaseCommand, logger, debug *log.Logger) *cobra.Command
• type BaseCommand
• type Broker
• type Config
• type ConsumerGroup
• type GroupMember
• type GroupOffset
• type PartitionMetadata
• type Topic

Functions

func Command

func Command(base BaseCommand, logger, debug *log.Logger) *cobra.Command

Types

type BaseCommand

type BaseCommand interface {
	Configuration() *internal.Configuration
	SaramaConfig() *sarama.Config
	ConnectClient(*sarama.Config) (sarama.Client, error)
	ConnectAdmin() (sarama.ClusterAdmin, error)
}

type Broker

type Broker struct {
	ID      int32  `table:"ID"`
	Address string `table:"ADDRESS"`
	Role    string `table:"ROLE" json:",omitempty" yaml:",omitempty"`
	Rack    string `table:"-" json:",omitempty" yaml:",omitempty"`
}

Broker contains information displayed by "kafkactl get brokers".

type Config

type Config struct {
	Name      string `table:"NAME"`
	Value     string `table:"VALUE"`
	Default   bool   `table:"DEFAULT"`
	ReadOnly  bool   `table:"READ_ONLY"`
	Sensitive bool   `table:"-"`
	Source    string `table:"-"`
}

Config contains information displayed by "kafkactl get config".

type ConsumerGroup

type ConsumerGroup struct {
	GroupID         string        `table:"GROUP_ID"`
	Protocol        string        `table:"-"`
	ProtocolType    string        `table:"-"`
	State           string        `table:"-"`
	CoordinatorID   int32         `table:"-"`
	CoordinatorAddr string        `table:"-"`
	Members         []GroupMember `table:"-"`
	Offsets         []GroupOffset `table:"-"`
	Clients         string        `table:"CLIENTS" json:"-" yaml:"-" table:"CLIENTS"`
	OffsetsSummary  string        `table:"OFFSETS" json:"-" yaml:"-"`
}

ConsumerGroup contains information displayed by "kafkactl get consumer".

type GroupMember

type GroupMember struct {
	ID         string
	ClientID   string
	ClientHost string
	Topics     []string
	UserData   json.RawMessage
}

GroupMember contains information displayed by "kafkactl get consumer".

type GroupOffset

type GroupOffset struct {
	Topic               string
	Partition           int32
	LastCommittedOffset int64
	HighWaterMark       int64 // the offset of the last message that was successfully copied to all of the log’s replicas
	PendingMessages     int64
}

GroupOffset contains information displayed by "kafkactl get consumer".

type PartitionMetadata

type PartitionMetadata struct {
	PartitionID     int32
	Leader          int32
	Offset          int64
	Replicas        []int32
	InSyncReplicas  []int32
	OfflineReplicas []int32
}

PartitionMetadata contains information displayed by "get topic".

type Topic

type Topic struct {
	Name              string
	Partitions        []PartitionMetadata `table:"-"`
	ConsumerGroups    []string            `table:"-"`
	NumPartitions     int32               `json:"-" yaml:"-" table:"PARTITIONS"`
	ReplicationFactor int16               `table:"REPLICATION"`
	Retention         string              `table:"RETENTION"`
	Configuration     map[string]*string  `table:"-"`
}

Topic contains information displayed by "get topic".