kafka 生产者调用MessageChannel.send() 消息发送确认问题
kafka
首先描述一下我的项目，springmvc与kafka整合用了spring-integration-kafka，1.3.0版本的。producer发日志主要用了MessageChannel.send()这个方法，kafka接收消息最大值我设置了5M,然后我就用一个4M文件以及5.2M文件作为消息内容测试，但是MessageChannel.send()每次都是返回true，很明显，4M文件kafka集群可以接收，返回true正确，而5.2M文件kafka集群是接收不了的，所以，请问下生产者如何才能确定消息被kafka集群成功接收？
看了一下kafka官方，单纯的0.10kafka-cilent.jar是有提供callback的，但是因为是整合到spring里面的，希望有热心人解答一下