admin

Sep 11, 2017

Changes in this version

+ type PartitionMetadata struct

+ ID int32

+ ISR []int32

+ Leader int32

+ Replicas []int32

type T

+ func (a *T) GetTopicMetadata(topic string, withPartitions, withConfig bool) (TopicMetadata, error)

+ func (a *T) ListTopics(withPartitions, withConfig bool) ([]TopicMetadata, error)

+ func (a *T) ResetKafkaClt()

+ type TopicConfig struct

+ Config map[string]string

+ Version int32

+ type TopicMetadata struct

+ Config *TopicConfig

+ Partitions []PartitionMetadata

+ Topic string

Dec 1, 2015

Changes in this version

+ const ProtocolVer1

+ type ErrInvalidParam error

+ type ErrQuery struct

+ func NewErrQuery(err error, format string, v ...interface{}) ErrQuery

+ func (e ErrQuery) Cause() error

+ func (e ErrQuery) Error() string

+ type ErrSetup error

+ type PartitionOffset struct

+ Begin int64

+ End int64

+ Metadata string

+ Offset int64

+ Partition int32

+ type T struct

+ func Spawn(config *config.T) (*T, error)

+ func (a *T) GetAllTopicConsumers(topic string) (map[string]map[string][]int32, error)

+ func (a *T) GetGroupOffsets(group, topic string) ([]PartitionOffset, error)

+ func (a *T) GetTopicConsumers(group, topic string) (map[string][]int32, error)

+ func (a *T) SetGroupOffsets(group, topic string, offsets []PartitionOffset) error

+ func (a *T) Stop()