kafkahelper

Documentation

Index

• Variables
• func NewConsumerHelper() *kafkaConsumerHelper
• func NewProducerHelper() *kafkaProducerHelper
• type KafkaConsumerHanddler
• type KafkaConsumerHelperCallback
• type KafkaProducerHelperCallback

Variables

var ConsumerHelper = NewConsumerHelper()

var ErrHelperAlreadyInited = errors.New("proxy already inited yet")

ErrHelperAlreadyInited 代理已经初始化错误

var ErrHelperNotInited = errors.New("proxy not inited yet")

ErrHelperNotInited 代理未初始化错误

var ProducerHelper = NewProducerHelper()

Functions

func NewConsumerHelper

func NewConsumerHelper() *kafkaConsumerHelper

NewConsumerHelper 创建一个kafka客户端代理

func NewProducerHelper

func NewProducerHelper() *kafkaProducerHelper

NewProducerHelper 创建一个新的数据库客户端代理

Types

type KafkaConsumerHanddler

type KafkaConsumerHanddler func(msg *kafka.Message)

KafkaConsumerHanddler kafka消费端的处理程序

type KafkaConsumerHelperCallback

type KafkaConsumerHelperCallback func(consumer *kafka.Consumer) error

KafkaConsumerHelperCallback KafkaProducer操作的回调函数

type KafkaProducerHelperCallback

type KafkaProducerHelperCallback func(producer *kafka.Producer) error

KafkaProducerHelperCallback KafkaProducer操作的回调函数