kafka

Documentation

Index

• func NewKafkaBroker(addrs []string, pttMode PartitionerMode, cnmMode ConsumerMode) (broker.Broker, error)
• type ConsumerMode
• type PartitionerMode

Functions

func NewKafkaBroker

func NewKafkaBroker(addrs []string, pttMode PartitionerMode, cnmMode ConsumerMode) (broker.Broker, error)

Types

type ConsumerMode

type ConsumerMode int8

const (
	CnmNewest ConsumerMode = 1 // 最新
	CnmOldest ConsumerMode = 2 // 最老
)

type PartitionerMode

type PartitionerMode int8

const (
	PttHash       PartitionerMode = 1 // hash
	PttManual     PartitionerMode = 2 // 手工
	PttRandom     PartitionerMode = 3 // 随机
	PttRoundRobin PartitionerMode = 4 // 轮询调度
)