get

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

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"`
}

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:"-"`
}

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:"-"`
}

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

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
}

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

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:"-"`
}

type TopicDetail struct {
	sarama.TopicDetail
	Partitions []*sarama.PartitionMetadata
}