kafka生产者发送消息失败导致内存溢出java.lang.OutOfMemoryError:Java heap space，请教如何解决？

最近使用spring集成kafka的api来自动监听并生产消息，发送消息使用如下api：
org.springframework.kafka.core.kafkaTemplate.sendDefault("your msg")，做压力测试时，正常情况下高并发生产消息都OK；

但模拟在kafka集群挂掉的情况下继续高并发发送消息时，发现生产者所在的服务很快会挂掉，weblogic抛出异常java.lang.OutOfMemoryError: Java heap space;

个人理解是生产者发送大量消息失败时GC并不能及时回收而导致的jvm堆内存溢出；

请教下，如何控制kafka生产者发送消息失败时，不至于影响系统内存或生产者所在的应用服务？

生产消息的部分代码如下：

private static ExecutorService exec = Executors.newFixedThreadPool(10);
    exec.execute( new Runnable() {
        @Override
        public void run() {
        //发送消息到kafka
        KafkaProducerFactory.getKafkaTemplate().sendDefault("your msg");
        }
    });