kafkahelper

package
v0.18.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 9, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.13.0

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 added in v0.13.0

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 added in v0.15.0

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

func (*T) SetOffsets added in v0.13.0

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

func (*T) ZKConn added in v0.16.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL