tidb_kafka

package
v0.9.26 Latest Latest
Warning

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

Go to latest
Published: Mar 11, 2019 License: Apache-2.0 Imports: 23 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	BinlogCheckInterval = time.Second
)

Functions

func KafkaPositionValueDecoder added in v0.9.19

func KafkaPositionValueDecoder(value string) (interface{}, error)

func KafkaPositionValueEncoder added in v0.9.19

func KafkaPositionValueEncoder(v interface{}) (string, error)

func ParseTimeStamp

func ParseTimeStamp(tso uint64) uint64

Types

type BinlogTailer

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

func NewBinlogTailer

func NewBinlogTailer(
	pipelineName string,
	serverID uint32,
	positionCache position_store.PositionCacheInterface,
	config *gCfg.SourceTiDBConfig,
	emitter core.Emitter,
	binlogChecker binlog_checker.BinlogChecker,
) (*BinlogTailer, error)

func (*BinlogTailer) Close

func (t *BinlogTailer) Close()

func (*BinlogTailer) Start

func (t *BinlogTailer) Start() error

func (*BinlogTailer) Wait

func (t *BinlogTailer) Wait()

type ConsumerGroupOffset added in v0.9.17

type ConsumerGroupOffset map[string]TopicOffset

type KafkaOffsetStoreFactory

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

func NewKafkaOffsetStoreFactory

func NewKafkaOffsetStoreFactory(pipelineName string, positionCache position_store.PositionCacheInterface) *KafkaOffsetStoreFactory

func (*KafkaOffsetStoreFactory) GenOffsetStore

type KafkaPositionValue added in v0.9.17

type KafkaPositionValue struct {
	Offsets map[string]ConsumerGroupOffset `json:"offsets"`
}

type OffsetStore added in v0.9.17

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

func (*OffsetStore) Close added in v0.9.17

func (store *OffsetStore) Close() error

func (*OffsetStore) CommitOffset added in v0.9.17

func (*OffsetStore) FetchOffset added in v0.9.17

type TopicOffset added in v0.9.17

type TopicOffset map[int32]int64

Jump to

Keyboard shortcuts

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