kafkahelper

Documentation

Index

• type T
  • func New(c *C) *T
  • func (kh *T) Client() sarama.Client
  • func (kh *T) Close()
  • 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) PutMessages(prefix, topic string, keys map[string]int) map[string][]*sarama.ProducerMessage
  • func (kh *T) ResetOffsets(group, topic string)

Types

type T

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

func New

func New(c *C) *T

func (*T) Client

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

func (*T) Close

func (kh *T) Close()

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) 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)