teckafka

type SelfStruct struct {
    BaseHandlerConsumer       
}

//处理业务前
func (b *SelfStruct) PreCallBack(msg []byte) error {
    return nil
}
//处理业务
func (b *SelfStruct) CallBack(msg []byte) error {
    return nil
}
//处理业务后
func (b *SelfStruct) PostCallBack(msg []byte) error {
    return nil
}
//错误处理
func (b *SelfStruct) DealErrCallBack(errMsg string) {

}

StartConsumer(SelfStruct{}, gkafka.V1_0_0_0,  []string{"ip1","ip2"}, "groupName", "topicName")

自定义两个方法、分别是处理正确回调和错误回调函数、如果不自定义则调用两个默认处理函数

    /**
    *	自定义错误回调处理方式
     */
    func errFn(err *sarama.ProducerError) {
        logger.Error(fmt.Sprintf("err:++++%+v++++", err))
    }
   /**
   *	自定义成功回调处理方式
    */
   func successFn(msg *sarama.ProducerMessage) {
    logger.Info(fmt.Sprintf("success:----%+v------", msg))
   }

发送消息

1. 使用自定义函数

   参数: 实例  topic  消息体 key 成功回调函数 失败回调函数
   msg, err := Publish(0, "test", "test", nil, successFn, errFn)
   if err != nil {
      fmt.Println(err)
      return
   }
   

2. 使用默认函数

   参数: 实例  topic  消息体 key 成功回调函数 失败回调函数
   _, err := Publish(0, "test", "test", nil, DefaultSuccessFn, DefaultErrFn)