配置 #

核心组件 #

数据结构 #

KafkaProducer.send() #

异常处理 #

Tips

1. 直接抛出异常到最上层的调用方法
2. 封装成错误码，返回给最上层调用者
3. 对异常情况做一些统计
4. 在特殊的异常记录类里，记录下来发生的异常

• 业务系统
  封装错误码
• 中间件系统

1. 同步调用，直接抛出来
2. 异步调用，回调你的回调函数，告知错误信息

Sender #

申请内存 #