Kafka系列2:深入理解Kafka生产者( 八 )

  • 如果Kafka返回错误 , onComplete方法会抛出一个非空异常 。 在调用send()方法的时候会传入这个callback对象 , 根据发送的结果决定调用异常处理方法还是发送结果处理方法 。

  • 生产者配置

    在创建生产者的时候 , 介绍了三个必须的属性 , 本节再一一介绍下其他的生产者属性:

    acks

    acks 参数指定了必须要有多少个分区副本收到消息 , 生产者才会认为消息写入是成功的: