kafkahelper

Documentation

Index

• type T
  • func New(c *C) *T
  • func (kh *T) Close()
  • func (kh *T) GetCommittedOffsets(group, topic string) []offsetmgr.Offset
  • func (kh *T) GetMessages(topic string, begin, end []int64) [][]string
  • func (kh *T) GetNewestOffsets(topic string) []int64
  • func (kh *T) GetOldestOffsets(topic string) []int64
  • func (kh *T) KafkaClt() sarama.Client
  • func (kh *T) PutMessages(prefix, topic string, keys map[string]int) map[string][]*sarama.ProducerMessage
  • func (kh *T) ResetOffsets(group, topic string)
  • func (kh *T) SetOffsetValues(group, topic string, offsetValues []int64)
  • func (kh *T) SetOffsets(group, topic string, offsets []offsetmgr.Offset)
  • func (kh *T) ZKConn() *zk.Conn

Types

type T

type T struct {
	// contains filtered or unexported fields
}

func New

func New(c *C) *T

func (*T) Close

func (kh *T) Close()

func (*T) GetCommittedOffsets

func (kh *T) GetCommittedOffsets(group, topic string) []offsetmgr.Offset

func (*T) GetMessages

func (kh *T) GetMessages(topic string, begin, end []int64) [][]string

func (*T) GetNewestOffsets

func (kh *T) GetNewestOffsets(topic string) []int64

func (*T) GetOldestOffsets

func (kh *T) GetOldestOffsets(topic string) []int64

func (*T) KafkaClt

func (kh *T) KafkaClt() sarama.Client

func (*T) PutMessages

func (kh *T) PutMessages(prefix, topic string, keys map[string]int) map[string][]*sarama.ProducerMessage

func (*T) ResetOffsets

func (kh *T) ResetOffsets(group, topic string)

func (*T) SetOffsetValues

func (kh *T) SetOffsetValues(group, topic string, offsetValues []int64)

func (*T) SetOffsets

func (kh *T) SetOffsets(group, topic string, offsets []offsetmgr.Offset)

func (*T) ZKConn

func (kh *T) ZKConn() *zk.Conn