Kafka Producer 的 Apache Camel 内存泄漏答案

【问题标题】：Apache Camel Memory Leak with Kafka ProducerKafka Producer 的 Apache Camel 内存泄漏
【发布时间】：2018-07-22 22:16:53
【问题描述】：

我正在使用 Apache Camel 2.20.2（连同 Spring Boot 1.5.8）将通过 MQTT 传入的消息路由到其他两个服务，一个是 HTTP/SOAP（工作正常），另一个是 Apache Kafka。

在一夜之间以每分钟大约 320 条消息的初始运行后，我注意到该过程变得非常缓慢。经过一些分析，我发现 Kafka 路由产生了内存泄漏（确定禁用了 HTTP 路由）。

@Component
public class Router extends RouteBuilder {

    @Autowired
    ApplicationProperties param;

    @Override
    public void configure() throws Exception {
        logger.info("Starting MqttKafkaBridgeApplication with:\n" + param.toString());

        // MQTT Consumer
        from("mqtt:vernemq?"
                + "host=tcp:MqttHost:MqttPort...")
        .transform(body().convertToString())
        .log("Recieved : "+body().convertToString())
        .multicast()
        .stopOnException().to( "direct:kafka");

        // Kafka Producer
        from("direct:kafka")
            .process(new Processor() {
                @Override
                public void process(Exchange exchange) throws Exception {
                    exchange.getIn().setHeader(KafkaConstants.PARTITION_KEY, 0);
                    exchange.getIn().setHeader(KafkaConstants.KEY, "1");
                }
            })
            .to("kafka:" +  "kafkaTopic"  +
                "?brokers=kafkaHost:KafkaPort;
    }
}

我是骆驼的新手，但据我所知，我的配置很简单？我可以看到消息到达 Kafka 集群，所以不知道为什么没有释放内存？

来自 visualvm 的屏幕截图，可以看到字节数和 char 数组随着每条消息的增长而增长：

【问题讨论】：

也许我读错了，但这不是真正的 Kafka 对象而不是 Camel Route 部分吗？

标签： java spring-boot apache-kafka apache-camel

【解决方案1】：

经过进一步调查，看起来 Camel 使用的内存与您提供的内存一样多，只要 GC 运行一切看起来都很好。我现在运行的应用程序没有在 docker 容器中进行任何重大更改，并且没有任何与内存相关的问题。

【讨论】：