kafka 设置了ack应答后,回调函数的意义
时间: 2023-10-05 07:06:34 浏览: 80
SpringBoot整合Kafka配置类方式
当Kafka Producer 发送消息时,可以设置 acks 参数来控制确认消息是否已经成功写入了Broker。当 acks 参数设置为 all 或 -1 时,表示 Producer 等待所有备份都完成后才会收到一个确认。在这种情况下,回调函数的意义是当所有备份都已成功写入 Broker 后,Kafka Producer 会调用回调函数来通知 Producer 发送消息成功。回调函数中可以对消息发送的成功与否进行处理,例如打印日志或进行下一步操作等。如果 acks 参数设置为 0 或 1,则不需要等待所有备份完成,因此不需要使用回调函数。
阅读全文