Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "kafka-producer-network-thread | producer-1"这样的问题有人遇到过吗

这个项目是处理实时数据的，接到上游的实时数据之后通过Spring Integration分发到kafka里面。

数据是一条一条过来的，每过来一条数据就立即发往Kafka集群。

然后就报

Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "kafka-producer-network-thread | producer-1"

这种错误。

这是因为实时数据量比较大，一条一条地向kafka集群发送数据网络速度跟不上，数据积压在内存里面导致了OOM吗？

求大神指导！