kafka

Documentation

Index

• Variables
• func NewKafkaClient(brokers []string, netConfig *config.KafkaNetConfig) (sarama.Client, error)
• type KafkaAsyncProducer
  • func NewKafkaAsyncProducer(mqConfig *config.KafkaGlobalConfig, ...) (*KafkaAsyncProducer, error)
• type KafkaMetaData

Variables

var MsgVersion = sarama.V0_10_2_0

Functions

func NewKafkaClient

func NewKafkaClient(brokers []string, netConfig *config.KafkaNetConfig) (sarama.Client, error)

Types

type KafkaAsyncProducer

type KafkaAsyncProducer struct {
	sarama.AsyncProducer
	// contains filtered or unexported fields
}

func NewKafkaAsyncProducer

func NewKafkaAsyncProducer(mqConfig *config.KafkaGlobalConfig, partitionerConstructor sarama.PartitionerConstructor) (*KafkaAsyncProducer, error)

type KafkaMetaData

type KafkaMetaData struct {
	InputSequenceNumber int64
	InputStreamKey      string
	MysqlPositionConfig utils.MySQLBinlogPosition
}