live.lumia.config

接口 KafkaSendCallBack

public interface KafkaSendCallBack

作者:

lc

方法概要

限定符和类型	方法和说明
void	before(String topic, String msg) 发送前
void	fail(String topic, String msg) 发送失败
void	success(org.springframework.kafka.support.SendResult<String,String> stringStringSendResult, String msg) 发送成功

方法详细资料

before

void before(String topic,
            String msg)

发送前

参数:

topic - topic

msg - message

success

void success(org.springframework.kafka.support.SendResult<String,String> stringStringSendResult,
             String msg)

发送成功

参数:

stringStringSendResult - res

msg - message

fail

void fail(String topic,
          String msg)

发送失败

参数:

topic - topic

msg - message